は、コードのこの部分を考慮受信

Question

におけるForkJoinの結果を集計しますSubscribe（）はIEnumerable<Book>の配列です。

ForkJoin（）の結果を集計する他の方法はありますか？ Merge（）とForkJoinのようなものを使うことを望んでいました。

Answer 1

すべての3つのサービスがBooksのリストを返し、あなたがリストをマージするSelectManyを使用することができますと仮定：

IObservable<Book> loadAll = 
    Observable.ForkJoin(
     service1.FindBooksAsObservable().Select(s => s), 
     service2.FindBooksAsObservable().Select(s => s), 
     service3.FindBooksAsObservable().Select(s => s) 
    ) 
    .Select(books => books.SelectMany(list => list).ToList()); 

loadAll.Subscribe(
    book => { /* will be called once with a single list of all items */ }); 

リストする出力を必要としない場合は、ToList()呼び出しを削除することができます。

Answer 2

Observable.ForkJoinはReactive Extensions（Rx）（v2.1.30214.0）の最新の安定版ではありません。 2013年6月現在のForkJoinは、Rxの実験版のみです。

デイブ・セクストンは、周りの仕事を示唆した： http://social.msdn.microsoft.com/Forums/en-US/rx/thread/3cfccb74-9ce3-47dc-94fd-cf60270c1ed5