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: ... }

我想得到 observable：

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(...);