何时使用 IEnumerable 与 IObservable？

Question

如何确定一个方法应该返回IEnumerable<T> 还是IObservable<T>？

为什么我会选择一种范式而不是另一种？

Answer 1

类型

• IEnumerable<T>
  • 你反复从T的序列中“拉”
• IObservable<T>
  • T 的序列正在向您“推送”

为什么我会选择一种范式而不是另一种？

您通常不“选择”一种范式而不是另一种范式。通常，一个会自然而然地成为正确的选择，而另一个则没有任何意义。

示例

考虑以下示例：

• 一个巨大的 CSV 文本文件的每一行都有一个项目，您想一次处理一个项目，而不是一次将整个文件加载到内存中：IEnumerable<List<string>>

• 您正在运行 HTTP Web 服务器：IObservable<WebRequest>

• 您希望以广度优先的方式获取树数据结构的节点：IEnumerable<Node>

• 您正在响应用户界面按钮点击：IObservable<Click>

在每个示例中（尤其是 IObservable<T> 案例），使用其他类型是没有意义的。

但如果我想使用“其他”类型怎么办...

IObservable<T> 到 IEnumerable<T>

如果某事物自然是IObservable<T>，但您想将其视为IEnumerable<T>，则可以使用以下方法：

IEnumerable<T> Observable.ToEnumerable(this IObservable<T>)

• 当T 被IObservable<T>“推送”时，它会被发送到队列中。
• 当您尝试将 T 从 IEnumerable<T> 中“拉出”时，它会阻塞直到队列不为空，然后出队。

IEnumerable<T> 到 IObservable<T>

如果某事物自然是IEnumerable<T>，但您想将其视为IObservable<T>，则可以使用以下方法：

IObservable<T> Observable.ToObservable(this IEnumerable<T>)

• .NET 线程池中的线程将反复尝试从 IEnumerable<T> 中“拉”T。
• 每次它“拉”T，它都会通过IObservable<T>“推”你。

Answer 2

如果你想推送数据给你的方法的调用者在你方便的时候，使用IObservable<T>。您可以通过在Observers 上调用OnNext() 来执行此操作，该兴趣通过Subscribe() 注册。

如果您希望方法的调用者拉数据方便时，请使用IEnumerable<T>。他们通过调用GetEnumerator() 来获取IEnumerator 并调用MoveNext() 和Current（foreach 编译为此）来做到这一点。

更新：也许最好举一些例子：

返回银行货币价格的函数非常适合IObservable<T>。这里的信息是时间关键的。作为此数据的服务器，您需要尽快将其发送到客户端。客户端不知道该数据何时准备就绪。所以你把它推给他们。

返回特定金融工具的有效交易日并用于填充日历控件上的停电日的函数是 IEnumerable 的良好候选者。此数据很少更改，并且客户端（设置控件）更喜欢以它指定的速度使用它。

Answer 3

IObservable<T> 是一个专用接口，可用于发布/订阅和各种其他模式。您会知道何时需要返回 IObservable<T>，因此如果没有特定需要，请返回 IEnumerable<T>。

更新评论中的问题

基本上，IObservable<> 使用“推送”机制，而 IEnumerable 使用“拉取”机制。如果您只想获取不需要通知订阅者更改（推送）的数据列表，那么您可以使用IEnumerable。如果订阅者（窗口、控件、其他客户端程序/例程等）需要知道数据何时更改，则使用IObservable<>。一个例子是使用 IObservable 从子线程更新 windows 程序中的主 UI 线程（通常，如果没有花哨的步法，这将无法完成。阅读 .NET Reactive Extensions (Rx.NET)。

Answer 4

使用IEnumerable<T> 表示列表，使用IObservable<T> 表示事件。轻松愉快。