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

现有主题正在使用中：

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 to fooSubject？它看起来像是一个可以由库本身处理的操作.

解决方法

由于Subject已经是方法next(),error()和complete()的观察者,你只需将它订阅到任何Observable：

const fooSubject = new BehaviorSubject(null);

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

barSubject.next('bar');