Cancelation Token für beobachtbare

Question

Wie kann ich den folgenden Typ von Rx Observable abbrechen, wenn die folgende Observable bei einem StartButton-Klick erstellt wird, d. H. Von einer Stop-Schaltfläche.

var instance = ThreadPoolScheduler.Instance; 

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

Answer 1

eine Gerechter Gebrauch der Überlastung von Subscribe, die eine nimmt CancellationToken:

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

Dieses Beispiel Jon Skeet vereinfacht:

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

Sie behalten die IDisposable, die von Subscribe zurückgegeben wurde, und Dispose auf es nennen.

Es kann gut sein, eine Möglichkeit, die Rx IDisposable -basierte Abmelde der Integration mit CancellationToken aus der Box, aber nur Dispose ruft ein Anfang wäre. (Sie können immer nur eine Fortsetzung des Widerruf Token registrieren zu nennen verfügen ...)

Hier ist ein kurzes, aber vollständiges Beispiel zu demonstrieren:

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