如何使用 rxjs 5.5.2 导入

Question

我不明白应该如何导入 RXjs 运算符。

看看这个简单的代码。

import 'rxjs/add/operator/filter';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/debounce';

ngOnInit() {
    const temp_observable = this.store.select(state => state.accounts.pendingRequests)
      .filter(x => !!x)
      .map(x => x +1 )
      .debounce(x => Observable.timer(300));
}

但我不断得到：

ERROR TypeError: this.store.select(...).filter(...).map(...).debounce is not a function

当我使用导入时也会发生同样的事情：

import {map, filter, debounce} from 'rxjs/operators';

但是，如果我将代码更改为使用 Observable.of，它会起作用-

const temp_observable = Observable.of(this.store.select(state => state.accounts.pendingRequests))

有没有更简单的方法来解决这个问题？ 我可以在 main.ts 中导入常用运算符，而不用担心每个 .ts 文件吗？

rxjs 5.5.2 角度 5.0.3 角度还原 6.0.1 节点 8.9.1

Answer 1

自从引入 pipeable（以前 lettable）运算符以来，使用建议发生了一些变化。试试这个代码 sn-p -

import { debounce, filter, map } from 'rxjs/operators';

ngOnInit() {
  const temp_observable = this
    .store.select(state => state.accounts.pendingRequests)
    .pipe(
      filter(x => !!x),
      map(x => x +1 ),
      debounce(x => Observable.timer(300))
    );
}

希望这会有所帮助。