c# - C# Reactive Extensions - IObservable のアイテムを反復処理する>

Question

最近、 C#rxのバージョンをいじり始めましたが、次の問題をどのように解決できるのか疑問に思っています。

次の方法でサーバーからアイテムのリストを取得するためにrefitを使用しています。

[Get("/items")]
IObservable<List<Item>> GetItems();

後で各アイテムを処理したいのですが、その方法がわかりませんでした。RxJava には、各項目を処理できるようにするという演算子があることは知っていますが、 C#flatMapIterable()に似たものは見つかりませんでした。

ありがとう

Answer 1

ドキュメントによると、.SelectMany.

[Get("/items")]
IObservable<List<Item>> GetItems() 
{
    observable.SelectMany(t => t);
}

興味があれば、Rx.NET repoでソースの実装を確認できます。