0

的的IObservable我有以下的Rx查詢產生的IObservable問題是,它不會發布()這樣的用戶數量的增加也是如此的memmory負荷工作的Rx發佈()破壞XDocuments

// Works 
Observable 
    .Interval(TimeSpan.FromSeconds(1.0)) 
    .Select(_ => XDocument.Load("http://test.com/data.xml")); 

// Broken 
Observable 
    .Interval(TimeSpan.FromSeconds(1.0)) 
    .Select(_ => XDocument.Load("http://test.com/data.xml")).Publish(); 

有沒有更好的方式來創建這樣的Observable?

+0

「不適用於Publish()」是什麼意思? – 2012-02-23 16:14:53

+0

在發佈之後,您沒有連接()。 – 2012-02-23 20:49:06

回答

2

在你調用Connect()之前,IConnectableObservable與源代碼斷開連接,所以沒有任何事情會發生(Interval不會啓動它的計時器),直到有人訂閱它爲止。 Connect()將使Publish訂閱其源。