IOS RxSwift从Observable数组创建Observable数组

Question

我正在构建一个链函数,其流程取自前一个函数的结果并循环遍历每个元素做一些计算并最终返回原始数组

我有

func(A) -> Observable<[Object]>
func(B)(Object) -> Observable<Object>

我们如何制作这样的链接？

Observable<[Object]> -> [Observable<Object>] -> Observable<[Object]>

Answer 1

您可以使用'flatMap'运算符链接函数:

funcA().flatMap{ objects in 
    Observable.from(objects)
}
.flatMap{ eachObject in
    funcB(eachObject)
}