rxjs - Rx.Subject 是一个热门的 observable 吗？

Question

编码

const a = new Rx.Subject().do(x => console.log('a'))
const b = a.mapTo(0)
const c = a.mapTo(1)
const d = Rx.Observable.merge(b, c)
d.subscribe(x => console.log('d'))
a.next(3)

和输出

a
d
a
d

为什么 a 打印了两次？ Rx.Subject 不是一个热门的 observable 吗？

Answer 1

Subject本身是热的/共享的。

但是:您附加的任何(大多数!)运算符都将创建一个新流，并将前一个流(在本例中为 Subject )作为源 - 但是，新流(对于大多数运算符)不是热的，只会被制作通过附加热运算符(如 share 或 publish 等...)

所以当你share您的 do ，一切都应该按预期工作。

const a = new Rx.Subject().do(x => console.log('a')).share();
const b = a.mapTo(0);
const c = a.mapTo(1);
const d = Rx.Observable.merge(b, c)
d.subscribe(x => console.log('d'));
a.next(3);

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>