我想采用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); });