在observer.error()之后需要调用observer.complete()吗？

Question

我在Angular 2中编写了一个observable.我的代码是这样的:

Observable.create(observer => {
    // fetched something from web service
    if (some condition) {
        observer.next('something');
        observer.complete();
    }
    else { // error with no data
        observer.error('something else');
        observer.complete(); // Is this required here? Or can I skip this in case of error() ?
    }
});

Answer 1

你不需要打电话complete,因为你error已经打过电话,它不会做任何事情.

Doc说:http://reactivex.io/documentation/observable.html

根据Observable合约的条款,它可以调用onNext零次或多次,然后可以通过调用onCompleted或onError而不是两者来跟随这些调用,这将是它的最后一次调用

你可以看一下源代码:

• https://github.com/ReactiveX/rxjs/blob/master/src/Subscriber.ts#L120

• https://github.com/ReactiveX/rxjs/blob/master/src/Subscriber.ts#L108