来自 RxJS 承诺的流

Question

我正在尝试在我根据承诺创建的流上运行reduce。

在下面的示例中，myApi.getItemsAsync() 返回一个数组。

我希望reduce 回调会被数组中的每个单独的项目调用。相反，它是用整个数组调用的。

Rx.Observable.fromPromise(
  myApi.getItemsAsync()
)
.reduce(function (acc, item) {
  // expecting `item` to be a single item
  // instead, seeing the entire array
}, [])
.subscribe(function (result) { 
  console.log(result);
});

如果myApi.getItemsAsync() 是一个返回数组的同步函数，则reduce 将按预期工作，并使用数组中的每个项目调用回调。

我如何让它与 Promise 一起使用？

Answer 1

reduce 正在处理整个流，而不是作为其一部分发出的数组。

如果你想使用数组方法，那么它应该是

Rx.Observable.fromPromise(myApi.getItemsAsync())
.map(function(array) {
  return array.reduce(function (acc, item) {
    return …;
  }, []);
})
…

如果您希望使用流方法，那么您需要先将数组项注入流中。我猜在你的同步版本中你使用了fromArray。再加上一个承诺，你会做的

Rx.Observable.fromPromise(myApi.getItemsAsync())
.flatMap(function(array) {
  return Rx.Observable.fromArray(array);
}).reduce(function (acc, item) {
  return …;
}, [])
…