javascriptObservables：链接诺言并在每个诺言上触发事件

我刚刚读了RxJS Promise Composition (passing data)这个问题,有一个问题.

设置与上述问题相同：我有3个诺言.

const p1 = () => Promise.resolve(1);
const p2 = x => { const val = x + 1; return Promise.resolve(val); };
const p3 = x => {
const isEven = x => x % 2 === 0;
return Promise.resolve(isEven(x));
};


根据答案,我将它们链接起来,如下所示：

var chainedPromises$=
Rx.Observable.just()
.flatMap(p1)
.flatMap(p2)
.flatMap(p3);


但是,chainedPromises $在所有promise链的末尾仅触发一次,且解析值为true.即：

chainedPromises$.subscribe(function(x){console.log(x)}); // Logs `true`


如何更改chainedPromises $,以便在每个承诺结束时触发一次？即：

chainedPromises$.subscribe(function(x){console.log(x)});
// Logs `1`
// Logs `2`
// Logs `true`


解决方法:

看起来您需要发出生成的值并在链的下一步中使用它.我不知道这是否有糖,但是我通过明确区分来使它起作用.

Observable
.fromPromise(p1())
.flatMap(val => Observable.merge(
Observable.fromPromise(p2(val))
.flatMap(val => Observable.merge(
Observable.fromPromise(p3(val)),
Observable.of(val)
)),
Observable.of(val)
))
.subscribe(console.log);


您可以看到it正常工作.