RX：件名RefCountプロパティは

Question

0私は次のように単純なクラスを持って到達したときに廃棄を実行し

internal class DataProvider : IDataProvider 
{ 
    private readonly Subject<string> _dataChangeSubject = new System.Reactive.Subjects.Subject<string>(); 
    private IObservable<string> _dataChangeObservable; 

    public IObservable ObserveDataChange() 
    { 
     return _dataChangeObservable ?? (_dataChangeObservable = _dataChangeSubject.Publish().RefCount()); 
    } 
} 

上記通知するSubject.OnNext()を呼び出す他のコードを持っている実際のクラス、のちょうど抽出物であります変更。

私が知りたいのは、公開されたサブジェクトのRefCountがいつ0になったかを知ることができれば、そのサブジェクトを処分して他のクリーンアップ操作を実行できるということです。

Answer 1

RefCount（）を使用すると、サブスクリプションが0になるとシーケンスが完了します。したがって、Finallyを使用してシーケンスの完了をリスンすることができます。例：

internal class DataProvider 
{ 
    private readonly Subject<string> _dataChangeSubject = new System.Reactive.Subjects.Subject<string>(); 
    private IObservable<string> _dataChangeObservable; 

    public IObservable<string> ObserveDataChange() 
    { 
     return _dataChangeObservable ?? 
      (_dataChangeObservable = _dataChangeSubject.Finally(() => { /* Do cleanup here */ }).Publish().RefCount()); 
    } 
}