Обратите внимание: это продолжение вопроса . выложили ранее но интересующее решение другой ситуации.
Я пытаюсь сделать несколько вызовов методов, каждый из которых возвращает IObservable, но значения, возвращаемые обратно в операторе SelectMany, являются задачей, и, следовательно, следующий оператор Subscribe не компилируется.
Это фрагмент кода
var myWorkList = new List<MyWork>
{
new MyWork(),// MyWork.Execute(data) returns IObservable
new MyWork()
}.ToObservable();
var results =
myService
.GetData(accountId)
.SelectMany(data => myWorkList.ForEachAsync(r => r.Execute(data))
.Subscribe(result =>
{
Console.WriteLine($"Result Id: {result.Id}");
Console.WriteLine($"Result Status: {result.Pass}");
});