Я хотел бы использовать RXJS Observable. В основном это работает нормально, но мне нужно не просто реагировать, когдаobserver.next () но и когдаobserver.complete () называется. Как я могу получить событие OnComplete RXJS Observable? На мой взгляд, документ 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);
        });
    }
}