Observable.Generate in RxJava？

Question

.NET Reactive Extensions有一個簡潔的方法來使用稱爲Observable.Generate的corecursion生成序列。

RxJava中是否有類似的方法可以通過corecursion生成數據？如果沒有，是否可以基於現有方法實施？

Answer 1

這不是一個確切的比賽，但我們有SyncOnSubscribe（和AsyncOnSubscriber），可以產生價值，例如：

@Test 
public void testRange() { 
    final int start = 1; 
    final int count = 4000; 
    OnSubscribe<Integer> os = SyncOnSubscribe.createStateful(new Func0<Integer>(){ 
     @Override 
     public Integer call() { 
      return start; 
     }}, 
     new Func2<Integer, Observer<? super Integer>, Integer>() { 
      @Override 
      public Integer call(Integer state, Observer<? super Integer> subscriber) { 
       subscriber.onNext(state); 
       if (state == count) { 
        subscriber.onCompleted(); 
       } 
       return state + 1; 
      } 
     }); 

    @SuppressWarnings("unchecked") 
    Observer<Object> o = mock(Observer.class); 
    InOrder inOrder = inOrder(o); 

    Observable.create(os).subscribe(o); 

    verify(o, never()).onError(any(TestException.class)); 
    inOrder.verify(o, times(count)).onNext(any(Integer.class)); 
    inOrder.verify(o).onCompleted(); 
    inOrder.verifyNoMoreInteractions(); 
}