5

我有一个基于某些事件的 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 中是否有推荐的方法来实现这一点。迁移文档没有提供任何建议。

4

1 回答 1

5

经过更多研究后,我发现我所描述的行为可以用

.publishBehavior(startValue).refCount().

这一发现是share()基于publish().refCount(). 我仍然不完全理解publish(),但这似乎在实践中产生了预期的效果。

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

于 2016-05-04T15:54:11.873 回答