RxJS 迁移 5 到 6 - 使用 TakeUntil 取消订阅

Question

在 RxJS 6 中取消订阅的最佳方式是什么？

我的“旧”RxJS 5 代码如下所示

export class MyComponent implements OnInit, OnDestroy {
  private ngUnsubscribe: Subject<any> = new Subject();

  this.myService.myEventEmitter
    .takeUntil(this.ngUnsubscribe)
    .subscribe(this.onDataPolling.bind(this));

  public ngOnDestroy(): void {
    this.ngUnsubscribe.next();
    this.ngUnsubscribe.complete();
  }
}

在迁移到 RxJS 6 时，我运行 rxjs-5-to-6-migrate 并得到了

this.myService.myEventEmitter.pipe(
  takeUntil(this.ngUnsubscribe))
  .subscribe(this.onDataPolling.bind(this));

但这不起作用，因为 EventEmitter 没有管道方法。

在 RxJS 6 中取消订阅的最佳方式是什么？

编辑：这在全新安装后确实有效，并且是在 RxJS 6 中取消订阅的最佳方式。

Answer 1

import { takeUntil } from 'rxjs/operators';

.pipe(takeUntil(this.destroyed$)).subscribe({YOUR_CODE})

这应该会有所帮助。

Answer 2

this.ngUnsubscribe.complete();

到

this.ngUnsubscribe.unsubscribe();