共享的observable和startWith运算符

Question

我有一个关于多重观察和一个意外(对我来说)行为的问题,我注意到了.

const a = Observable.fromEvent(someDom, 'click')
  .map(e => 1)
  .startWith(-1)
  .share();

const b = a.pairwise();

a.subscribe(a => {
  console.log(`Sub 1: ${a}`);
});

a.subscribe(a => {
  console.log(`Sub 2: ${a}`)
});

b.subscribe(([prevA, curA]) => {
  console.log(`Pairwise Sub: (${prevA}, ${curA})`);
});

因此,有一个共享的observable a,每次点击事件都会发出1.由于startWith运算符,会发出-1.可观察的b只是通过配对来自a的最新两个值来创建一个新的observable.

我的期望是:

[-1, 1] // first click
[ 1, 1] // all other clicks

我观察到的是:

[1, 1] // from second click on, and all other clicks

我注意到的是-1值立即发出并被Sub 1消耗,甚至在Sub 2订阅了observable之前,由于a是多播的,因此Sub 2对于派对来说太迟了.

现在,我知道我可以通过BehaviourSubject进行多播,而不是使用startWith运算符,但是当我使用startWith和通过share进行多播时,我想了解这种情况的用例.

据我所知,每当我使用.share()和.startWith(x)时,只有一个订阅者会收到有关startWith值的通知,因为所有其他订阅者在发出值后都会被订阅.

这是通过一些特殊主题(行为/重播......)进行多播的原因,还是我错过了关于这个startWith/share场景的内容？

谢谢!

Answer 1

这实际上是正确的行为.

在.startWith()发出其值设置为每一个新的用户,不仅是第一个.b.subscribe(([prevA, curA])永远不会收到它的原因是因为你正在使用.share()(又名.publish().refCount())多播.

这意味着第一个a.subscribe(...)使.refCount()订阅它的源并且它将保持订阅(注意Observable .fromEvent(someDom, 'click')永远不会完成).

然后,当你最终打电话时,b.subscribe(...)它只会订阅Subject内部,.share()并且永远不会通过,.startWith(-1)因为它是多播并且已经订阅了.share().