可観測トークンのキャンセルトークン

Question

StartButtonクリック、つまり停止ボタンで次のような観察可能オブジェクトが作成されている場合は、どのようにしてRx Observableのタイプを取り消すことができますか？

var instance = ThreadPoolScheduler.Instance; 

Observable.Interval(TimeSpan.FromSeconds(2), instance) 
        .Subscribe(_ => 
        { 
        Console.WriteLine(DateTime.Now); // dummy event 
        } 
        );   

Answer 1

ちょうど取るSubscribeのオーバーロードのいずれかを使用します。

はここで証明するために、短いながら完全な例です（あなたはいつもちょうど...処分呼び出すためにキャンセルトークンで継続を登録することができ） CancellationToken：

observable.Subscribe(_ => Console.WriteLine(DateTime.UtcNow), cancellationToken); 

これはジョンスキートの例を簡素化：

using System; 
using System.Reactive.Concurrency; 
using System.Reactive.Linq; 
using System.Threading; 

class Program 
{ 
    static void Main(string[] args) 
    { 
     var instance = ThreadPoolScheduler.Instance; 
     var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5)); 

     Observable.Interval(TimeSpan.FromSeconds(0.5), instance) 
      .Subscribe(_ => Console.WriteLine(DateTime.UtcNow), cts.Token); 
     Thread.Sleep(10000); 
    } 
} 

Answer 2

あなたはSubscribeによって返されたIDisposableを保持し、それにDisposeを呼び出します。

ありも箱から出してCancellationTokenとRxのIDisposableベースの退会を統合する方法かもしれませんが、ちょうどDisposeを呼び出すと、スタートになります。

using System; 
using System.Reactive.Concurrency; 
using System.Reactive.Linq; 
using System.Threading; 

class Program 
{ 
    static void Main(string[] args) 
    { 
     var instance = ThreadPoolScheduler.Instance; 
     var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5)); 

     var disposable = Observable 
      .Interval(TimeSpan.FromSeconds(0.5), instance) 
      .Subscribe(_ => Console.WriteLine(DateTime.UtcNow)); 
     cts.Token.Register(() => disposable.Dispose()); 
     Thread.Sleep(10000); 
    } 
}