Rx Publish () нарушает IObservable XDocuments

Question

У меня есть следующий запрос Rx, который вызывает проблему IObservable, это то, что он не работает с Publish (), так как количество подписчиков увеличивается, а память загружается

// 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();

Есть ли лучший способсоздание такой наблюдаемой?

Answer 1

Пока вы не вызовете Connect (), IConnectableObservable отсоединяется от своего источника, поэтому ничего не произойдет (интервал не запустит свой таймер), пока кто-нибудь не подпишется на него. Connect () заставит публикацию подписаться на ее источник.