提供三种 RxBus:
- 没有背压处理(Backpressure)的 Rxbus
- 有背压处理的 RxBus
- 有异常处理的 Rxbus (订阅者处理事件出现异常也能继续收到事件)
RxJava 操作符 阅读本文前请先了解 RxJava 的基本使用。 参考文档: RxJava JavaDoc ReactiveX文档中文翻译 1 Observable 的创建 1.1 from( ) 转换集合为一个每次发射集合中一个元素的 Observable 对象。可用来遍…
提供三种 RxBus:
RxJava 操作符 阅读本文前请先了解 RxJava 的基本使用。 参考文档: RxJava JavaDoc ReactiveX文档中文翻译 1 Observable 的创建 1.1 from( ) 转换集合为一个每次发射集合中一个元素的 Observable 对象。可用来遍…
Copyright © 2019- yule263.com 版权所有 湘ICP备2023023988号-1
违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com
本站由北京市万商天勤律师事务所王兴未律师提供法律服务