typescript – RXJS Observable doSomething onComplete

发布时间：2020-12-17 08:46:29 所属栏目：安全来源：网络整理

导读：我想使用RXJS Observable.基本上它工作正常,但我不仅需要在observer.next()时做出反应,而且还需要在调用observer.complete()时做出反应. 如何获得RXJS Observable的OnComplete事件？在我看来,RXJS文档令人困惑. export class Service { myMethod():Observabl

我想使用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);
        });
    }
}

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);
    });
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!