完成 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

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

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

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

在 this issue 中进行了长时间的讨论，他们决定 'Remove shareBehavior and shareReplay to prevent user confusion.' 我不明白混淆的可能性是什么（所以也许这意味着我是用户之一这个决定拯救了？）。

publishBehavior 看起来也很有前途，但我不完全理解 publish 并且它似乎增加了比我需要或想要的更多的复杂性。

无论如何，我想知道在 RxJS 5 中是否有推荐的方法来完成此操作。migration doc 没有提供任何建议。

Answer 1

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

实现

.publishBehavior(startValue).refCount().

这一发现是基于 share() 是 publish().refCount() 的别名这一事实。我还是不完全理解publish()，但这在实践中似乎达到了预期的效果。

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

完成 shareValue/shareBehavior

Accomplishing shareValue/shareBehavior

rxjs5