RxJava - スキャンとフラットマップを組み合わせる方法はありますか？

Question

私はStringとlongを受け取り、Single<String>を返す関数を持っているとしましょう。

Single<String> stringAddition(String someString, long value) { 
    return Single.just(someString + Long.toString(value)); 
} 

今、私はこれを行う方法の損失でよ、このObservable ...

Observable.interval(1, SECONDS) 
    .scan("", (cumulativeString, item) -> { 
    // Need to return the result of stringAddition(cummulativeString, item) 
    }); 

を持っています。スキャンでStringを返す必要がありますが、私はSingle<String>を返すメソッドを使用します。私には、scanとflatMapの両方の動作を組み合わせることができるものが必要なようです。私を助けるRxJava2ウィザードがありますか？

Answer 1

次のようにして実現できます。なぜあなたが最初の場所で ``シングル を返さない stringAdditionが Observable

Observable<String> scanned = Observable.interval(1, TimeUnit.SECONDS) 
      .scan(
        Observable.just(""), 
        (cumulativeString, item) -> 
         cumulativeString 
          .flatMap(str -> stringAddition(str, item).toObservable()) 
      ) 
      .flatMap(it -> it);