復位和處置觀察到的用戶，無擴展

Question

假設我有這樣的：

public class UploadDicomSet 
{ 
    public UploadDicomSet() 
    { 
     var cachCleanTimer = Observable.Interval(TimeSpan.FromMinutes(2)); 
     cachCleanTimer.Subscribe(CheckUploadSetList); 
     //Start subscriber 
    } 
    void CheckUploadSetList(long interval) 
    { 
     //Stop and dispose subscriber 
    } 
    public void AddDicomFile(SharedLib.DicomFile dicomFile) 
    { 
     //Renew subscriber, call CheckUploadSetList 2 minutes later 
    } 
} 

由1- CheckUploadSetList我想處置或AddDicomFile完成觀察到

2 - 我想重置它

作爲評論的方法。

UPDATE：

我能做到這一點通過Timer爲：

public class UploadDicomSet : ImportBaseSet 
{ 
    Timer _timer; 
    public UploadDicomSet() 
    { 
     _timer = new Timer(CheckUploadSetList, null, 120000, Timeout.Infinite); 
    } 

    void CheckUploadSetList(object state) 
    { 
     Logging logging = new Logging(LogFile); 
     try 
     { 
      _timer.Dispose(); //Stop the subscription 
           //dispose everything 
     } 
     catch (Exception exp) 
     { 
      logging.Log(ErrorCode.Error, "CheckUploadSetList() failed..., EXP:{0}", exp.ToString()); 
     } 
    } 
    public void AddDicomFile(SharedLib.DicomFile dicomFile) 
    { 
     _timer.Change(120000, Timeout.Infinite); 
    } 
} 

在此先感謝。

Answer 1

使用反應擴展只是一些計時器功能似乎對我來說有點矯枉過正。爲什麼不爲這個使用普通的定時器，並在給定的時間啓動/停止它？

讓我給個想法。

public class UploadDicomSet : ImportBaseSet 
{ 
    IDisposable subscription; 

    public void CreateSubscription() 
    { 
     var cachCleanTimer = Observable.Interval(TimeSpan.FromMinutes(2)); 

     if(subscription != null) 
      subscription.Dispose(); 

     subscription = cachCleanTimer.Subscribe(s => CheckUploadSetList(s)); 
    } 

    public UploadDicomSet() 
    { 
     CreateSubscription(); 
     // Do other things 
    } 

    void CheckUploadSetList(long interval) 
    { 
     subscription.Dispose(); // Stop the subscription 
     // Do other things 
    } 

    public void AddDicomFile(SharedLib.DicomFile dicomFile) 
    { 
     CreateSubscription(); // Reset the subscription to go off in 2 minutes from now 
     // Do other things 
    } 
} 

背景材料

我真的可以推薦這些網站：

http://www.introtorx.com/

http://rxwiki.wikidot.com/101samples

Answer 2

你應該使用Switch()對於這種事情。

事情是這樣的：

public class UploadDicomSet : ImportBaseSet 
{ 
    IDisposable subscription; 
    Subject<IObservable<long>> subject = new Subject<IObservable<long>>(); 

    public UploadDicomSet() 
    { 
     subscription = subject.Switch().Subscribe(s => CheckUploadSetList(s)); 
     subject.OnNext(Observable.Interval(TimeSpan.FromMinutes(2))); 
    } 

    void CheckUploadSetList(long interval) 
    { 
     subject.OnNext(Observable.Never<long>()); 
     // Do other things 
    } 

    public void AddDicomFile(SharedLib.DicomFile dicomFile) 
    { 
     subject.OnNext(Observable.Interval(TimeSpan.FromMinutes(2))); 
     // Reset the subscription to go off in 2 minutes from now 
     // Do other things 
    } 
}