发生错误时,rxjs observable无法完成

Question

当我从头创建一个observable并且有观察者错误然后完成时,永远不会调用订阅的完成部分.

var observer = Rx.Observable.create(function(observer){
    observer.onError(new Error('no!'));
    observer.onCompleted();
})

observer.subscribe(
    function(x) { console.log('succeeded with ' + x ) },
    function(x) { console.log('errored with ' + x ) },
    function() { console.log('completed') }
)

输出是:

errored with Error: no!

我希望它是:

errored with Error: no!
completed

如果我更改代码以调用onNext而不是onError,则observable正确完成:

var observer = Rx.Observable.create(function(observer){
    observer.onNext('Hi!');
    observer.onCompleted();
})

observer.subscribe(
    function(x) { console.log('succeeded with ' + x ) },
    function(x) { console.log('errored with ' + x ) },
    function() { console.log('completed') }
)

我得到了预期的输出:

succeeded with Hi! 
completed

发生错误时为什么不完整？

Answer 1

那是因为错误意味着完成,因此onCompleted永远不会调用与之关联的回调.你可以在这里查看Rxjs observables合约(http://reactivex.io/documentation/contract.html):

Observable可以生成零个或多个OnNext通知,每个通知代表一个发出的项目,然后它可以通过OnCompleted或OnError通知跟踪这些发射通知,但不能同时通过两者.在发出OnCompleted或OnError通知后,它可能不会再发出任何通知

有关错误管理,您可以查看:https: //github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/errors.md

Answer 2

要在 observable 完成或出错时运行回调，您应该使用finalize.

前任：

this.service.yourObservable
            .pipe(
               finalize(() => {
                 // * This will always run when observable finishes the stream
                 console.log("Finally!");
                 // * callback for finally
                })  
             ).subscribe(
              {
               next: () => { // * Callback for success },
               error: () => { // * Callback for error },
               complete: () => {// * This gets called only on success }
              })

Answer 3

当我遇到同样的问题时,我碰到了这个github问题.

显然finally,Observable在这种情况下需要使用对象的方法.

从该线程引用Aleksandr-Leotech:

完成,最后是完全不同的事情.完成意味着可观察的蒸汽成功完成.因为你可以有很多成功的电话.最后意味着蒸汽已成功或未成功结束.

HTTP请求并不明显,但想象另外两种情况.

1. 鼠标事件.你将收到一个永无止境的成功回调,但你永远不会收到或完成,因为用户事件永远不会停止(除非你用错误的代码触发异常,然后你会得到错误,最后).

2. 使用Web套接字.您将获得多次成功回调,但在某个时间点,您与后端的通信将停止,您将获得完整和最终,除非您有一些错误,这将调用错误,最后.

因此,您可能会获得多次或没有成功调用,零或一次错误调用,零或一个完整,零或一个最终.

Answer 4

Another and probably the simplest solution might be using add() function.
In this case the statement will be always executed regardless error occured or call succeded (alike finally in most programming languages).

observer.subscribe(
    function(x) { console.log('succeeded with ' + x ) },
    function(x) { console.log('errored with ' + x ) },
    function() { console.log('completed') }
)
.add(() => {
    console.log("Will be executed on both success or error of the previous subscription")
);