c# - IEnumerable を変換する方法> IObservable へ

Question

IEnumerable<Task<T>> を IObservable<T> に変換する組み込みの方法はありますか。順序は関係ありません。できれば完了したときに取得します。

まだ存在しない場合、それを達成するための良い方法は何でしょうか?

score 7 · Accepted Answer

私はこれがうまくいくと信じています

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

各タスクは、完了した順序に関係なく、その結果をオブザーバブルシーケンスに送信します。シーケンスをサブスクライブして、その結果に対して必要なことを何でも行うことができます。

score 2 · Accepted Answer

あなたはこのようにすることができます：

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

または、代わりに、次のようにします。

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

score 1 · Accepted Answer

あなたが探しているのはObservable.Start()

次に、最後に追加.Subscribe(callbackMethod)して、必要に応じてコールバックを指定できます。

score 0 · Accepted Answer

Rx 2.0 では、もう少し簡単な方法があります。

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

4 に答える 4