RxJS 从 onNext 结果创建一个列表

Question

我想要 return 来自

的转换元素列表

function transformElements(list) {
  return Rx.Observable.from(list)
    .map(rxFunctions.mapFunction);
}

问题是，如果我订阅 transformElements，我将收到 onNext 中的每个转换元素，但我想要的是将整个转换元素列表发送到 return 在另一种方法中，比方说，getAllElements.

我应该使用什么 Rx 运算符来做到这一点？

提前致谢:)

Answer 1

Observable#toArray() 运算符应该做你想做的。当应用于 Observable 序列时，它会生成一个新的 Observable 序列，该序列会发出一项：一个包含源 Observable 序列的所有元素的数组。

RxJS create a list from onNext result