我刚刚读了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正常工作.