我正在尝试使用以下代码throttle ngrx存储操作更新事件

import 'rxjs/add/operator/throttle'
import { Dispatcher, Store } from '@ngrx/store';
...
static get parameters() {
  return [[Dispatcher]];
}
constructor(actions$) {
...

this.actions$
  .filter(action => action.type === this.Actions[`LOAD_USERS_REQUEST`])
  .throttle(1000 /* ms */)
  .subscribe(() =>
    ...
  );

这引发了我一个错误



当我用.throttle(1000)替换.throttle(() => 1000)时,它抛出了一个不同的错误,清楚地显示了 throttle 期望的功能,而不是我提供的功能。但是我不知道为什么,因为文档指出 throttle 需要一个数值。

https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/throttle.md

最佳答案

您在https://github.com/Reactive-Extensions/RxJS上引用的文档页面与RxJS 4有关。由于您使用的是Angular2,因此您在使用RxJS 5。

运算符 throttle() 希望将Observable或Promise作为参数。

运算符 throttleTime() 以毫秒为单位作为参数时间。

因此,您应该使用throttleTime(1000)

请注意,使用.throttle(() => 1000)非常不同。您传递了一个匿名函数,该函数直接返回1000而不是1000号。这就是为什么它会引发其他错误。

关于angular - rxjs节流this.durationSelector不是一个函数,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/40106953/

10-11 11:31