使用Publish().RefCount()

Question

我发现自己经常想用来Publish().RefCount()"保护我的来源".

例如,将一些传入的IObservable json转换为两个IObservable属性时:

var anon = source.Select(TranslateToAnonObject);
this.Xs = anon.Select(GetXFromAnonObject);
this.Ys = anon.Select(GetYFromAnonObject);

为了避免两次执行翻译,我很想Publish().RefCount()在anon定义后面加上一个.

对于两个属性值也是如此,以避免Get..为每个订户单独执行功能.

问题是,它已经到了我无法真正看到许多我不想要的情况.但如果这是正确的,那肯定是Rx的默认值.我在想什么？

(想一想:是因为我几乎只与'热'观察者合作？)

Answer 1

你经常想要这样做.事实上,我在这一点上写了一篇文章.它不是默认值的原因很简单,它不是一直需要的(并且比关闭更容易省略); 在很多情况下,它只是增加了开销,并且在一些情况下需要使用带有连接控制的Publish(),因为订阅者数量可能会降至零并且重新订阅会产生意想不到的副作用,特别是(如您所说)处理冷观察时.