RxJS 6：仅订阅onComplete

Question

我不关心next()或error()的值。在subscribe()函数中，我是否仍需要定义空函数作为回调函数？

- user10324719

Answer 1

你可以像这样做

subscribe({
  complete: () => { // do the stuff you need to do on completion }
})

subscribe 允许您传递一个包含3个属性的对象，next、error 和 complete，它们分别指向相应的函数。每个属性都是可选的。

- Picci

Answer 2

事实上，您可以仅使用以下内容而无需任何处理程序：

.subscribe()

然而，这并不处理 error 通知（这些将被抛到全局错误处理程序），所以您可能还想使用以下内容来忽略所有错误：

.subscribe({ error: () => {} })

- martin

Answer 3

在 RxJS 6 中，这将除了 complete 之外的所有通知都去掉，并且还会在出错时完成：

obs$.pipe(
    ignoreElements(),
    catchError(() => EMPTY))
.subscribe(null, null, _ => console.log("complete"));

在您的subscribe中，仍需要传递空函数或undefined给next和error参数。

- ggradnig

Answer 4

你只能使用 "finally" 方法在 onComplete 事件上进行绑定 :-

myObservable.finally(onCompleteHandler);

你可以在这里查看：https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/finally.md。

- blue112

---

这将触发observer.error()和observer.complete()。 - user10324719

请注意，finally不会触发myObservable的执行。您仍然需要在最后订阅它。 - ggradnig

类型 Observable 上不存在方法。 - JesseBoyd

Answer 5

您仍然可以设置

.subscribe(undefined, undefined, () => {/* On complete */})

省略任何不必要的subscribe执行

- Tomas