Учитывая этот кусок кода:
var loadAll =
Observable.ForkJoin(
service1.FindBooksAsObservable().Select(s => s),
service2.FindBooksAsObservable().Select(s => s),
service3.FindBooksAsObservable().Select(s => s)
);
loadAll.Subscribe(
result =>
{
var aggregatedListOfBooks = result.SelectMany(b => b);
});
Как видите, проблема заключается в том, что каждый метод FindBooksAsObservable () возвращает IObservable<IEnumerable<Book>>
, поэтому переменная result в Subscribe () Массив IEnumerable<Book>
.
Есть ли другой способ агрегирования результата ForkJoin () ? Я надеялся использовать что-то вроде Merge () вместе с ForkJoin.