observable.takeUntil... 和 observable.pipe(takeUntil

Question

你能解释一下 observable.takeUntil 和 observable.pipe(takeUntil...) 有什么区别吗？

例子：

this.api
        .testMethod(
            this.queryParam,
        )
        .takeUntil(this.destroy$)
        .subscribe(

this.api
        .testMethod(
            this.queryParam,
        )
        .pipe(takeUntil(this.destroy$))
        .subscribe(

当我写第一个选项时，我看到我需要从 'rxjs/operators' 导入...

Answer 1

它主要归结为使用的 RxJS 版本。 RxJS v5 和更早的版本允许链接运算符而不需要pipe。 RxJS v6+ 需要明确提及 pipe。

import 'rxjs/add/operator/takeUntil';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/tap';

this.api.testMethod(this.queryParam)
  .takeUntil(this.destroy$)
  .map(data => data)
  .tap(console.log)
  .subscribe();

RxJS v6+

import { takeUntil, map, tap } from 'rxjs/operators';

this.api.testMethod(this.queryParam).pipe(
  takeUntil(this.destroy$),
  map(data => data),
  tap(console.log)
).subscribe();