RxJS流由几个基本组件组成，对于整个流，每个组件都有相关的特定任务和生命周期。接下来给大家一一介绍：
- Producers
- Consumers
- Data pipeline
- Time
Producers
Producers是数据的来源。流必须始终有一个数据生产者，它将是在RxJS中执行的任何逻辑的起点。实际上，生产者是由独立生成事件的东西创建的(从单个值、数组、鼠标单击到从文件读取的字节流)。观察者模式将生产者定义为Subject；在RxJS中，我们称它们为Observables，就像在一些可观察的东西中一样。
Observables负责推送通知，因此我们将这种行为称为fire-and-forget，这意味着我们永远不会期望生产者参与事件的处理，只会参与事件的发射。
Consumers
与生产者相对应的是，我们必须还有一个消费者来接受生产者的事件并以某种特定的方式处理它们。当消费者开始侦听生产者以获取要消费的事件时，此时就生成了一个stream，并开始推送事件。我们将把消费者称为Observer。
流只从生产者到消费者传播，而不是相反。换句话说，用户在键盘上键入时会产生一些事件，这些事件将被其他进程消费。这就意味着理解了流就能知道如何将将应用程序的各个部分确定为上游或下游，从而确定数据将流动的方向。对于RxJS，流总是从上游的可观察对象流到下游的观察者，这两个组件是松散耦合的，这增加了应用程序的模块性，如下图所示。
例如，键盘事件处理程序将位于上游，因为它只生产事件，而不消费事件，而应该基于按键执行逻辑的代码将位于下游。在基本级别上，流只需要生产者和消费者。一旦后者能够开始接收来自前者的事件，您就有效地创建了一个流。现在你能用这些数据做什么?所有这些都发生在数据管道中。
Data Pipeline
RxJS的一个优势是，您可以在数据从生产者传递到消费者时操作或编辑数据。这就是Rxjs方法列(observable operators)发挥作用的地方。在路由中操作数据意味着我们可以将生产者产生的数据转化成消费者所需要的数据。这样做会促进生产者和消费者的解耦（单一原则），这对于代码的模块化来说是一个巨大的胜利。这种设计原则在大型JavaScript应用程序中通常很难实现，但是RxJS简化了这种设计模型。
Time
所有这些背后的隐含因素是Time。对于RxJS，所有拿来处理stream的东西背后都有一个基本的时间概念。时间因素渗透到我们目前讨论过的所有组成部分。这是一个需要掌握的重要又抽象的概念，后面会详细讨论。现在，只需要了解Time并不总是以正常的速度运行，可以构建运行得更慢或更快的流，这取决于自己的需求。幸运的是，如果决定使用RxJS，这不会成为问题。下图展示了一个RxJS流：
