Eu gostaria de usar o RXJS Observable. Basicamente, funciona bem, mas não preciso apenas reagir quandoobserver.next () mas também quandoobserver.complete () é chamado. Como obtenho o evento OnComplete de um Observável RXJS? Na minha opinião, o documento RXJS é confuso.

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