angular - 使用异步代码扫描操作符

Question

我通常使用这样的扫描:

Observable.interval(10).take(10).scan((acc, x) => acc.concat(x), []).subscribe...

现在，在 scan 的第一个参数中，我想传递一个获取 (acc, x) 并返回新 acc 的 Observable 的方法，而不是同步方法。 (例如，保存到 dB 并返回包含来自 db 的信息的已保存对象的方法，例如修订号，然后将其添加到累加器中)。

我找到了mergeScan operator这似乎正是我想要的签名，但我找不到任何示例，当我尝试时，我得到 Property 'mergeScan' does not exist on type Observable<number> .

我尝试的是这样的:

Observable.interval(10).take(10)
        .mergeScan((acc, x) => Observable.of(acc.concat(x)), [])
        .subscribe(x => console.log(x));

我在 Angular2 中使用 rxjs5

Answer 1

我可以在Rxjs 5.0.0-beta.6版本中看到这个运算符。

您是否尝试以这种方式导入运算符:

import 'rxjs/add/operator/mergeScan';