C# 反应式扩展 - 循环访问 IObservable<List 的项<Item>>

Question

我最近开始玩C#的rx版本，我想知道如何解决以下问题：

我正在使用改装通过从服务器获取项目列表

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

我想在之后处理每一项，但我不知道如何做到这一点。我知道在RxJava中有一个名为flatMapIterable()的运算符，它允许我处理每个项目，但我没有为C#找到类似的东西。

感谢

Answer 1

根据文档，您需要.SelectMany。

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

在Rx。NET回购，如果你感兴趣的话，你可以看看源代码的实现。

Answer 2

您需要SelectMany();

IObservable<List<Item>> observable = new List<List<Item>>().ToObservable();
var flattened = observable.SelectMany(i => i);