Ich möchte das RXJS Observable verwenden. Grundsätzlich funktioniert es gut, aber ich muss nicht nur reagieren, wenn observer.next () aber auch wenn observer.complete () wird genannt. Wie erhalte ich das Ereignis OnComplete eines RXJS Observable? Meiner Meinung nach ist das RXJS-Dokument verwirrend.

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