.net - RX : Execute an action when a subscription is started or disposed?

Question

我想跟踪IObservable的 Activity 订阅数吗？
我以为我可以通过在“某人”调用“订阅/处置”时增加/减少计数器来实现此目的。

我怎样才能做到这一点 ？
还是有更好的方法呢？

这似乎是由RefCount内部完成的，但未公开订阅计数器。

谢谢

Answer 1

最简单的方法是将Observable封装在Observable.Create中:

IObservable<string> myObs;

var returnObservable = Observable.Create<string>(subj => {

    // TODO: Write code to do stuff on Sub

    var disp = myObs.Subscribe(subj);

    return Disposable.Create(() => {
        disp.Dispose();

        // TODO: Write code to do stuff in unsub.
    });
});