我正在构建一个链函数,其流程将取自先前函数的结果,并循环遍历每个元素进行一些计算并最终返回原始数组
我有
func(A) -> Observable<[Object]>
func(B)(Object) -> Observable<Object>
我们如何进行这样的链接?
Observable<[Object]> -> [Observable<Object>] -> Observable<[Object]>
您可以使用“ flatMap”运算符链接功能:
funcA().flatMap{ objects in
Observable.from(objects)
}
.flatMap{ eachObject in
funcB(eachObject)
}
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句