angular - observer.error()之后需要调用observer.complete()？

Question

我正在用 Angular 2 编写一个可观察对象。我的代码是这样的:

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。

文档说:http://reactivex.io/documentation/observable.html

By the terms of the Observable contract, it may call onNext zero or more times, and then may follow those calls with a call to either onCompleted or onError but not both, which will be its last call

你可以看看源码:

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

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