Observables 顾名思义，是可以被观察的事务。在 Rxjs 的上下文里，Observable 会随着时间的推移，在某个时间点产生数据。

Observables 可以：

• 不停地（永远）产生值，比如 interval 操作符。
• 可以一次性生产价值，然后进入 complete 状态。
• 可能会产生错误，然后进入 complete 状态。

Observable 是一种异步事件的实现利器，例如单个操作（HTTP 请求）或多个可重复的操作（例如光标移动或按键）。

响应式编程(Reactive Programming)是一种构建应用程序的方法，它对应用程序内发生的变化做出响应，而不是编写应用程序来处理这些变化。后者是 Imperative Programming 即命令式编程的典型特征。

要理解 Observable 的设计原理，我们首先有必要了解典型的生产者和消费者通信的几种模式。

拉取(Pull)和推送(Push)模型定义了数据生产者如何与数据消费者合作。

Pull

拉取：在拉取模型的情况下，消费者决定何时使用或请求数据。 当我们创建一个返回值的函数时，该函数就是生产者。 但是，在调用该函数（或要求提供数据）之前，该函数不会产生任何内容。

调用函数的代码是消费者。 此调用按照消费者的需求被触发。 消费者决定传播策略。

Push

推送：生产者主导推模型。 任何使用数据的人都不知道数据何时到达。 他们知道数据到达时要做的应用逻辑，但消费者不决定数据何时到达。

Promise 是推送模型的经典示例。 当任务完成时，promise 会产生数据或错误。 传递给 Promise 的回调函数永远不会知道 Promise 何时完成，它只负责数据成功达到或者发生错误时，应该执行什么样的逻辑。

标签：Observable,消费者,Pull,拉取,rxjs,Push,数据
来源： https://www.cnblogs.com/sap-jerry/p/16304195.html