Publish().RefCount()不工作吗？

Question

我通过一个IObservable属性公开了一个稍微“昂贵”的计算。

如果有多个订阅者，我想防止它被多次运行，所以我在它后面放了一个Publish().RefCount()，但是当我插入断点时，我仍然看到它被调用了两次。

public IObservable<int> Property
{
    get { return _Source.Select(Expensive).Publish().RefCount(); }
}

Answer 1

这只是Publish().RefCount() 'protected‘的结果，而不是你的源代码--如果你对你的属性有多个调用，你会得到多个独立的'protected’观察值--每个观察值都会独立订阅你的源代码。

您需要一个支持字段，您可以确保该字段只定义一次：

private IObservable<int> _Property;
public IObservable<int> { get { return _Property; } }

//elsewhere:
_Property = _Source.Select(Expensive).Publish().RefCount()

(或者也可以选择)

public IObservable<int> { get; private set; }

//elsewhere:
_Property = _Source.Select(Expensive).Publish().RefCount()