RxRuby

需要转向反应式 |关于反应式扩展 |为什么是 RxRuby？ |贡献 |许可

反应式编程是近来的一个热门话题,尤其是像 Reactive Manifesto 这样的东西。应用程序的需求随着时间的推移发生了变化,从简单的数据轮询到数据被推送给你的全面反应式系统。每次,我们都在为应用程序添加更多的复杂性、数据和异步行为。我们如何管理这一切?我们如何进行扩展?通过转向"反应式架构",这些架构具有事件驱动、弹性和响应性。借助 Reactive Extensions,您拥有了构建这些系统所需的所有工具。

Reactive Extensions for Ruby (RxRuby) 是一组库,用于使用可观测序列和流畅查询运算符(许多 Ruby 开发者都已熟悉)编写异步和事件驱动程序。使用 RxRuby,开发人员可以使用 Observables 表示异步数据流,使用我们的多个运算符查询异步数据流,并使用 Schedulers 为异步数据流中的并发性进行参数化。简而言之, RxRuby = Observables + Operators + Schedulers。

使用 RxRuby,您可以表示多个异步数据流(来自不同来源,例如股票报价、推文、计算机事件、Web 服务请求等),并使用 Observer 模块订阅事件流。Observable 会在发生事件时通知已订阅的 Observer 实例。