Jak przekonwertować IEnumerable <Task<T>> do IObservable <T>

Question

Czy jest zbudowany w sposób przekonwertować IEnumerable < Zadanie <T> > do IObservable <T>. Porządek nie ma znaczenia, tylko że dostaję rzeczy, chociaż najlepiej, gdy są zakończone.

Jeśli jeszcze nie istnieje, jaki może być dobry sposób na jego wykonanie?

Answer 1

Wierzę, że to będzie działać

tasks.Select(t => Observable.FromAsync(() => t)) 
    .Merge(); 

Każde zadanie będzie wysyłać swoje wyniki do zaobserwowania sekwencji w dowolnej kolejności one kompletne. Możesz zapisać się do sekwencji i robić, co chcesz, z wynikami w ten sposób.

Answer 2

wierzę co szukasz może być Observable.Start()

Następnie można dołączyć .Subscribe(callbackMethod) do końca i określ zwrotnego w razie potrzeby.

Answer 3

Można zrobić to w ten sposób:

var query = tasks.ToObservable().SelectMany(task => task.ToObservable()); 

Lub alternatywnie, jak to:

var query = 
    from t in tasks.ToObservable() 
    from i in t.ToObservable() 
    select i; 

Answer 4

Od Rx 2.0, jest nieco łatwiejszy sposób:

var query = tasks.ToObservable().Merge();