我有一个基于某些事件的 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
允许迟到的订阅者获取当前值。但是,它似乎shareBehavior
在 RxJS 5 中被重命名为,然后被完全删除:
https://github.com/ReactiveX/rxjs/pull/588
https://github.com/ReactiveX/rxjs/pull/712
在这个问题上进行了长时间的讨论,决定他们将“删除 shareBehavior 和 shareReplay 以防止用户混淆”。我不明白混淆的可能性是什么(所以也许这意味着我是这个决定拯救的用户之一?)。
publishBehavior
看起来也很有希望,但我并不完全理解publish
,而且它似乎增加了比我需要或想要的更多的复杂性。
无论如何,我想知道在 RxJS 5 中是否有推荐的方法来实现这一点。迁移文档没有提供任何建议。