任何需要先为 RxJS 调用取消订阅（）

Question

在下面的代码中：-

RxJS.Observable.of(1,2).first().subscribe((x) => console.log(x););

是否有必要退订给运营商first()？

Answer 1

first() 将在第一个项目从 observable 发出后完成。

另外 subscribe() 接受三个参数，最后一个是完整的回调。运行以下代码将输出 1 后跟 'done'.

Rx.Observable.of(1)
  .subscribe(
  (x) => console.log(x),    // next
  (x) => console.error(x),  // error
  () => console.log('done') // done
)

Answer 2

对于提供的示例，您不需要 unsubscribe，也不需要调用 first，因为 Observable.of(1) 实际上完成在发出第一个（和最后一个）值之后。

Answer 3

没有。调用 first() 后自动取消订阅。 RxJS 6 的当前语法是 observable.pipe(first()).subscribe(func);。

If called with no arguments, first emits the first value of the source Observable, then completes.

Any need to call unsubscribe for RxJS first()