javascript - 管道 RxJS 可观察到现有主题

Question

有正在使用的现有主题:

const fooSubject = new BehaviorSubject(null);

还有另一个可观察对象(本例中的另一个主题):

const barSubject = new Subject();
barSubject.subscribe(
  value => fooSubject.next(),
  err => fooSubject.error(err),
  () => fooSubject.complete()
);

barSubject.next('bar');

代码有效但看起来很笨拙。

是否有更好的方法将barSubject observable 管道(广义上，不一定使用pipe 运算符)fooSubject？它看起来像是可以由库本身处理的操作。

Answer 1

由于 Subject 已经是具有方法 next()、error() 和 complete() 的观察者，您可以将其订阅到任何可观察的:

const fooSubject = new BehaviorSubject(null);

const barSubject = new Subject();
barSubject.subscribe(fooSubject);

barSubject.next('bar');