如何执行为 observable 返回的列表的每个元素返回单个并将其作为列表返回的操作？

Question

这个问题很复杂，但代码看起来更简单（我希望）

我有一个像下面这样的功能

fun trackFoos(): Observable<List<Foo>> {/*....*/}
fun getBarForFoo(fooState: Foo.State): Single<Bar>

而且我有一些代码绑定到应用程序的其他部分，所以我不能改变太多。

Observable.combineLatest(
              trackFoos(),
              Observable.interval(1, TimeUnit.SECONDS),
              BiFunction() {foos: List<Foo>, _:Long -> foos}
             ).subscribe { foos -> /*....*/ }

现在我还需要使用 getBarForFoo 为每个 foo 对象传递 Bar 对象

所以我需要使用trackFoos() 和getBarForFoo() 编写trackPairOfFooAndBar() 来使用它，如下所示：

Observable.combineLatest(
              trackPairOfFooAndBar(),
              Observable.interval(1, TimeUnit.SECONDS),
              BiFunction() {fooBarList: List<Pair<Foo,Bar>>, _:Long -> fooBarList}
             ).subscribe { fooBarList-> /*....*/ }

我看到了这个答案：https://stackoverflow.com/a/47676208/1461568 但假设第二次调用是可观察到的（我有单次调用）

那该怎么做呢？

Answer 1

你可以这样做：

1. 将trackFoos() 从Observable<List<Foo>> 转换为Observable<Foo>
2. 对于每个Foo 执行getBarForFoo() 并映射结果，使其真正返回Pair<Foo, Bar>
3. （可选）如果您需要Single<List<Pair<Foo,Bar>>>，您可以拨打toList()
4. （可选）如果您真的需要Observable，那么您可以拨打toObservable()

在代码中：

fun trackPairOfFooAndBar() : Observable<Pair<Foo, Bar>> {
    return trackFoos()            
            .flatMapIterable { it } // or flatMap {list -> Observable.fromIterable(list)}
            .flatMapSingle { foo -> getBarForFoo(foo.state).map { foo to it } }
            // optional, depending what is the final signature that you want
            //.toList().toObservable 
}