1

Reactive Extensions は初めてです。オブジェクトのコレクションがあり、各オブジェクトのメソッドを呼び出し、メソッドはブール値を返します。for eachループを使用してメソッドを呼び出してそれぞれをループする代わりに、リアクティブ拡張機能で、指定された数のオブジェクト(一度に5つなど)のメソッドを同時に呼び出し(フォークと結合)、最初のオブジェクトが実行された後に行う方法はありますか? 、6番目はメソッドを呼び出す必要があり、すべてのオブジェクトが完了するまで続行する必要があります。

ご回答ありがとうございます。

4

1 に答える 1

5 
IObservable<bool> someBoolAsyncMethod(SomeObject o)

someCollection.ToObservable()
    .Select(x => Observable.Defer(() => 
        someBoolAsyncMethod(x).Select(y => new { Item = x, Result = y})))
    .Merge(5)
    .ToList()
    .Subscribe(newListOfBools);
于 2012-04-16T20:30:25.243 に答える