011.理解事件(events)和流(streams)

在软件系统中，事件是一种用于指示发生了什么事情的消息。该事件可能代表一个技术事件——例如，在GUI应用程序中，您可能会在按下的每个键或每次鼠标移动上看到事件。该事件还可以表示业务发生，例如在金融系统中完成的货币交易。

事件由事件源引发，并由事件处理程序使用。正如您所看到的，事件是表示时变值的一种方式。在Rx中，事件源可以由可观察的表示，事件处理程序可以由观察者表示。但是，我们的应用程序正在使用的简单数据呢，比如数据库中的数据或从web服务器获取的数据。它在被动世界中有一席之地吗？

一、一切都是“流”
您编写的应用程序最终将处理某种数据，如图1.15所示。数据可以有两种类型：静止数据和运动数据。
在这里插入图片描述
图1.15运动数据和静止数据作为一个数据流。来自外部环境的连接点非常适合创建可观察性。这些可观测值可以很容易地与Rx合并，以创建合并的可观测值，内部模块可以在不知道数据元素的确切来源的情况下订阅该可观测值。

静态数据以数字格式存储，通常从数据库或文件等持久存储中读取。运动中的数据在网络（或其他介质）上移动，并被推送到您的应用程序或由您的应用从任何外部源提取。

无论您在应用程序中使用何种类型的数据，都应该明白，一切都可以作为流来观察，甚至是静止的数据和对应用程序来说看起来静态的数据。例如，配置数据被认为是静态的，但即使在某个时刻，配置也会发生变化，无论是在长时间还是短时间之后。从应用程序的角度来看，这并不重要；你想被动应对，并在这些变化发生时处理它们。当您将静止的数据视为另一个数据流时，可以更容易地组合这两种类型的数据。对于您的应用程序来说，数据来自何处并不重要。

例如，应用程序启动通常从其持久存储加载数据以恢复其状态（应用程序关闭前保存的状态）。当然，在应用程序运行过程中，这种状态可能会发生变化。应用程序的内部关心状态的部分可以查看承载它的数据流。当应用程序启动时，流将传递加载的数据，当状态发生变化时，流会承载更新。

我喜欢用一个很好的比喻来解释流，那就是水管，但这个水管有数据包穿过它，就像你在图1.16中看到的那样。当使用水管时，你可以用它做很多事情。你可以在末端安装过滤器。可以添加不同的软管头，以提供不同的功能。您可以添加压力监测器来帮助调节流量。您可以对数据流执行同样的操作。你会想要建立一个管道，让信息在其中流动，最终给出适合你逻辑的最终结果；这包括过滤、转换、分组、合并等等。

数据流和事件流非常适合Rx可观察性。使用IObservable对它们进行抽象使您能够合成运算符并创建复杂的执行管道。这与您对Shoppy示例所做的类似，在Shoppy示例中，对服务器的调用作为更复杂的执行管道的一部分获得了折扣，该管道还使用了过滤（在连接上）并最终刷新了视图（就像洒水喷头泼水一样）。

在这里插入图片描述
图1.16数据流就像一根软管：每一滴水都是一个数据包，需要经过各个站点，直到到达终点。您的数据还需要进行过滤和转换，直到它到达真正的处理程序，并对其进行有用的处理。