Promise to RxJs Observableに変換してください

Question

誰かがこの約束をRxJs observableに変換するのに役立つことができますか？ ローカルストレージからトークンを取得したいと思います。エラーの場合は、observableを購読しているオブザーバーにキャッチする必要があります。以下プロミスと既存のソリューションである：私は方法以下で観察に変換しようと

this.authService.getToken().then(token => { 
     this.token = token; 
    }).catch(() => console.log('Error! cannot get token')); 

：

getToken(): Promise<any> { 
    return new Promise<any>((resolve, reject) => { 
     resolve(JSON.parse(localStorage.getItem('currentUser')).token); 
     reject(); 
    }); 
    } 

と加入者である

getToken2(): Rx.Observable<number> { 
    return Rx.Observable.create(obs => { 
     obs.next(JSON.parse(localStorage.getItem('currentUser')).token); 
     obs.error('Error! cannot get token'); 
    }); 
    } 

と

this.authService.getToken2() 
    .subscribe((token) => console.log(token), (er) => console.log(er)); 

しかし、localstorageからトークンを取得中にエラーが発生した場合、RxJs observableはobs.next（）を介してそれをキャッチしません。それは正常に解決されたようです。Promiseはrejectメソッドで正常にキャッチします。アイデア何が間違っている？おかげ

Answer 1

あなたはこのすべてを行う必要はありません、ただ使用Observable.fromPromise()：

Observable.fromPromise(this.authService.getToken()) 
    ... 
    .subscribe(...) 

あなたが観察チェーンのどこにでも約束を使用する場合は、たとしても観察可能に変換する必要はありません。それは自動的に起こります。

https://medium.com/@benlesh/rxjs-observable-interop-with-promises-and-async-await-bebb05306875