我正在Kotlin中使用RxJava。
我有一个功能,transform(f: Foo): Single<Bar>
如何获取List
中的Foo
,并对它们中的每个执行transform
,以获得Flowable<Bar>
的结果,其中next
中的每个Flowable
是调用的结果transform
?
基本上,我需要一个功能
fun getFlowable(foos: List<Foo>): Flowable<Bar> {
// Runs transform() on each element of foos
// Concatenates the results to the flowable.
}
fun getFlowable(foos: List<Foo>, transform: (Foo) -> Bar): Flowable<Bar> = Flowable.fromIterable(foos.map(transform))
或更好的版本