我想获取一个Observable <T []>并将其转换为Observable <T>,以便将来自Observable <T []>的每个数组分解,然后分别通过发出该数组的各个元素Observable <T>。
是否有执行此操作的标准操作员?我已经搜索了,但是什么也没找到。谢谢。
指向concatMap / flatMap的方向后,我提出了以下一般解决方案:
var source: Observable<T[]>;
...
var splitSource = source.flatMap<T>((x:T[]) => { return Rx.Observable.fromArray(x); });
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句