rxjs Observable 设计原理背后的 Pull 和 Push 思路

Jerry Wang 发表于 2022/11/29 16:19:01 2022/11/29
【摘要】 Observables 顾名思义,是可以被观察的事务。在 Rxjs 的上下文里,Observable 会随着时间的推移,在某个时间点产生数据。

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

Observables 可以:

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

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

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

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

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

Pull

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

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

Push

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

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

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区),文章链接,文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:cloudbbs@huaweicloud.com进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。