C# 响应式扩展 - 遍历 IObservable> 的项目

Question

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

我正在使用 refit通过以下方式从服务器获取项目列表:

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

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

谢谢

Answer 1

根据文档，您需要 .SelectMany .

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

在Rx.NET repo ，您可以查看源代码的实现 - 如果您有兴趣。