RxJS动态观测源

Question

我想创建一个包含多个可观测对象的可观测对象(合并它们)。这可以通过merge(...arrayOfObservables)来实现。问题是，这个数组有时会被改变，可观测对象也应该订阅新的可观测对象。

Answer 1

您可以将新的可观察对象推送到一个数组，然后发出该数组并使用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