RxJava - Wie kombiniere ich Scan und FlatMap?

Question

Nehmen wir an, ich habe eine Funktion, die eine String und eine long nimmt und eine Single<String> zurückgibt.

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

Jetzt habe ich diese Observable ...

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

ich ratlos bin, wie dies zu tun. Scan benötigt mich, um eine String zurückzugeben, aber II möchte die Methode verwenden, die eine Single<String> zurückgibt. Für mich scheint es, als ob ich etwas brauche, das das Verhalten von scan und flatMap kombinieren kann. Gibt es irgendeine RxJava2-Zauberei, die mir helfen kann?

Answer 1

Sie können es wie folgt erreichen. Dies kann etwas verkürzt werden, wenn stringAdditionObservable zurückgekehrt

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

würde