发布().RefCount()不起作用？

Question

我通过IObservable属性暴露了一个温和的"昂贵"计算.

如果有多个订阅者,我想保护它不被多次运行,所以我在它后面放了一个Publish().RefCount(),但是当我坚持使用断点时,我仍然看到它被调用了两次.

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

Answer 1

这是唯一的结果的Publish().RefCount()这是"保护",而不是你的源-因为它的立场,如果你有你的财产多个呼叫,你会得到多个独立的 "保护"可观-这将分别认购分别到源.

您需要一个支持字段,您可以确保只定义一次:

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()