RxJS 绑定 Observable

Question

我在将可观察 A 的结果绑定到流可观察 B 时遇到问题，例如：

Rx.Observable.concat(
  A,
  A.bind(valuesInA =>
    B.scan((acc, value) => {
      acc.push(value);
      return acc;
    }, valuesInA)))

例如，如果是这种情况：

A: { onNext:[monkey], onComplete }
B: { onNext:banana, onNext:tree, onNext: ... }

我想获取可观察对象：

AB: { onNext:[monkey],
      onNext:[monkey, banana],
      onNext:[monkey,banana,tree],
      onNext: ... }

如果有一个绑定运算符，并且它在其被调用者完成时调用其回调，那就太好了，因为 A 完成得相当快（值的初始加载），然后 B 流式传输其余部分。

我该如何撰写？

Notes: B.scan( ... ) : Observable<Array<apeness>> so I need to subscribe its result

Answer 1

Flatmap、scan 和 startWith：

A.flatMap(a => B.scan((acc,v) => acc.concat(v), a).startWith(a))
 .subscribe(...);

RxJS bind Observable