訂閱多個observable的觀察者未完成

Question

我想了解RX，並正在爲兩個不同的observables訂閱創建的觀察者。

var observer = Observer.Create<string>(x => Console.WriteLine(x), 
      () => Console.WriteLine("Completed")); 

var subscription1 = Observable.Interval(TimeSpan.FromSeconds(1)) 
      .Select(x => "X" + x) 
      .Subscribe(observer); 

var subscription2 = Observable.Interval(TimeSpan.FromSeconds(2)) 
      .Select(x => "YY" + x) 
      .Subscribe(observer); 

Console.WriteLine("Unsubscribing in 5 seconds"); 
Thread.Sleep(5000); 
subscription1.Dispose(); 
subscription2.Dispose(); 

Console.WriteLine("All disposed"); 

我認爲在處置訂閱1後，觀察者將完成。我在這裏錯過了什麼？目前，我得到以下控制檯輸出從上面的代碼：

Unsubscribing in 5 seconds 
X0 
YY0 
X1 
X2 
YY1 
X3 
All disposed 

Answer 1

Observable.Interval創建了一個無限序列，所以你永遠不會得到「已完成」的消息。通過取消訂閱，您只需停止聽這個無限序列。

如果你想要完成序列，你可以使用類似Observable.Interval(...).Take(3)的東西。