Mã thông báo hủy cho quan sát được

Question

Làm cách nào tôi có thể hủy loại Rx quan sát được sau đây, nếu có thể quan sát được sau đây trên một nút StartButton, tức là từ nút dừng.

var instance = ThreadPoolScheduler.Instance; 

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

Answer 1

Chỉ cần sử dụng một trong những định nghĩa chồng cho Subscribe mà phải mất một CancellationToken:

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

này đơn giản hóa ví dụ Jon Skeet:

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

Bạn giữ IDisposable đã được trả về bởi Subscribe, và gọi Dispose trên đó.

Cũng có thể là cách tích hợp Rx IDisposable dựa trên đăng ký hủy đăng ký với CancellationToken ra khỏi hộp, nhưng chỉ cần gọi Dispose sẽ là khởi đầu. (Bạn có thể luôn luôn chỉ cần đăng ký một sự tiếp nối với các dấu hiệu hủy để gọi vứt bỏ ...)

Dưới đây là một ví dụ ngắn nhưng đầy đủ để chứng minh:

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