リセットと私はこれがあると、反応性の拡張

Question

、観察可能な加入者を処分：私はそれ

をリセットしたい AddDicomFileで観測可能

2-処分または終了したいCheckUploadSetListで

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-方法のコメントとして

。

UPDATE：

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); 
    } 
} 

事前に感謝を：

私はとしてTimerでそれを行うことができます。

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 
    } 
} 

私は本当にこれらのサイトをお勧めすることができます

背景素材：あなたはこの種のもののためにSwitch()を使用する必要があります

http://www.introtorx.com/

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

Answer 2

。このような

何か：

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 
    } 
}