RXJS Observable doSomething onComplete

Question

我想使用RXJS Observable.基本上它工作正常,但我不仅需要在observer.next()时做出反应,而且在调用observer.complete()时也是如此.如何获得RXJS Observable的OnComplete事件？在我看来,RXJS文档令人困惑.

export class Service {
    myMethod():Observable<any> {
        return Observable.create((observer:any) => {
        for(let i=0; i<10; i++) {
         observer.next(i);
        }
        if(true==true) {
            // this event I need
            observer.complete();
        } else {
            observer.error(xhr.response);
        }
    }
}

export class Component() {
    // constructor etc.

    doSome() {
        this.service.myMethod()
        // Here I would like to get OnComplete event
          .catch(this.handleError)
          .subscribe((num:any) => {
            console.log(num);
        });
    }
}

Answer 1

subscribe方法接受三个回调.最后一个是完整的事件.

doSome() {
  this.service.myMethod()
      .subscribe((num:any) => {
        console.log(num);
      }, (err) => {
        this.handleError(err);
      }, () => { // <----
        this.handleComplete();
      });
}

您也可以利用finally运算符.

doSome() {
  this.service.myMethod()
      .catch(this.handleError)
      .finally(this.handleComplete) // <----
      .subscribe((num:any) => {
        console.log(num);
    });
}

注意: 如果我们有错误,两个例子之间有区别:如果我们要添加console.logs,我们会看到在第一种情况下只handleError打印

-> handleError

在第二种情况下

-> handleError
-> finally

换句话说finally,总是被称为,complete不是.