Rxjs - 約束を呼び出し、順番に観測可能

Question

私は約束を返す関数を呼び出し、その結果を観測可能な値を返す別の関数に渡したいと思う。私はこれを順番に行い、観察可能な最終結果を得る必要があるので、私は購読することができます。例えば

：

// Call a function and return a Promise 
myPromise() {} 

// Make an http call and return an Observable 
myObservable() {} 

// Call myPromise() then call myObservable() and return 
// an Observable with the result 
// *I don't know how this function should be* 
myFunction() {} 

// Subscription 
myFunction().subscribe(
    result => console.log(result), 
    error => console.log(error), 
() => console.log('completed')); 

私はこれをどのように行うことができますか？

Answer 1

次の操作を行うことができます：

let stream$ = Observable.defer(() => Observable.fromPromise(myPromise())) 
    .flatMap(promiseResult => myObservable(promiseResult)); 

stream$.subscribe(obsResult => console.log(obsResult)); 

.deferは、すべてが初期化時に一度だけ加入し、そしてないとあなたの約束 - メソッドが呼び出されることを保証するために必要とされます。