rxjs5 - 实现shareValue/shareBehavior

Question

我有一个基于某些事件的 Observable，并且在某些时候做了一些昂贵的计算。我想在多个不同的地方呈现该 Observable 的结果。如果我天真地在两个地方订阅这个 Observable，我最终会做两次昂贵的计算。这是一个代码片段，可以将我的观点带回家:

var s = new rx.Subject();
var o = s.map(x => { console.log('expensive computation'); return x });
o.subscribe(x => console.log('1: ' + x));
o.subscribe(x => console.log('2: ' + x));
s.next(42);

输出是:

expensive computation
1: 42
expensive computation
2: 42

我只想在 map 中执行一次昂贵的计算。 share实现了这一点，但它使迟到的订阅者无法获得要呈现的当前值。在之前的 RxJS 版本中， shareValue允许迟到的订阅者获取当前值。但是，这似乎已重命名为 shareBehavior在 RxJS 5 中，然后完全删除:

https://github.com/ReactiveX/rxjs/pull/588

https://github.com/ReactiveX/rxjs/pull/712

在 this issue 里有很长的讨论决定他们将“删除 shareBehavior 和 shareReplay 以防止用户混淆”。我不明白混淆的可能性是什么(所以也许这意味着我是这个决定拯救的用户之一？)。
publishBehavior看起来也很有前途，但我不完全理解 publish它似乎增加了比我需要或想要的更多的复杂性。

无论如何，我想知道在 RxJS 5 中是否有推荐的方法来实现这一点。 migration doc不提供任何建议。

Answer 1

经过更多研究，我发现我所描述的行为可以通过

.publishBehavior(startValue) .refCount() .

这一发现是基于以下事实: share() 是 publish().refCount() 的别名.还没完全明白publish()但这在实践中似乎达到了预期的效果。

类似的是 cache(1) (这是 publishReplay(1).refCount() 的别名)。它与 publishBehavior(defaultValue).refCount() 有类似的效果。除了它不以默认值开头。因此，如果没有发出任何项目，新订阅者将不会立即收到值。