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 необходимо, чтобы гарантировать, что ваше обещание-метод вызывается с каждым подписываться, а не только один раз во время инициализации.