RxJS 动态可观察源

Question

我想创建一个由许多可观察对象组成的可观察对象(合并它们)。这可以通过 merge(...arrayOfObservables) 来实现。问题是，有时这个数组会发生变化，并且可观察对象也应该订阅新的可观察对象。

Answer 1

您可以将新的 Observables 推送到数组，然后发出该数组并使用 switchMap 订阅它们。

import { of, merge, BehaviorSubject } from 'rxjs'; 
import { switchMap } from 'rxjs/operators';

const s = new BehaviorSubject([of(1), of(2), of(3)]);

s.pipe(
  switchMap(array => merge(...array)),
).subscribe(x => console.log(x));

s.next([...s.getValue(), of(4)]);

现场演示:https://stackblitz.com/edit/rxjs-vmcqs9