- RxJava 教程
- RxJava - 主页
- RxJava - 概述
- RxJava - 环境设置
- 观测值
- RxJava - Observable 的工作原理
- RxJava - 创建 Observables
- RxJava - 单个可观察的
- RxJava - 也许可观察
- RxJava - 完整的可观察的
- RxJava - 使用 CompositeDisposable
- 运营商
- RxJava - 创建运算符
- RxJava - 转换运算符
- RxJava - 过滤运算符
- RxJava - 组合运算符
- RxJava - 实用操作符
- RxJava - 条件运算符
- RxJava - 数学运算符
- RxJava - 可连接运算符
- 科目
- RxJava - 主题
- RxJava - 发布主题
- RxJava - Behave主题
- RxJava-ReplaySubject
- RxJava-AsyncSubject
- 调度程序
- RxJava - 调度程序
- RxJava - 蹦床调度程序
- RxJava - 新线程调度程序
- RxJava - 计算调度程序
- RxJava - IO 调度程序
- RxJava - 来自调度程序
- 各种各样的
- RxJava - 缓冲
- RxJava - 窗口化
- RxJava 有用资源
- RxJava - 快速指南
- RxJava - 有用的资源
- RxJava - 讨论
RxJava - Observable 的工作原理
Observables代表观察者(订阅者)监听的数据源。简而言之,Observable 发出项目,然后 Subscriber 消费这些项目。
可观察的
一旦订阅者开始监听,Observable 就会提供数据。
Observable 可以发出任意数量的项目。
Observable 可以只发出完成信号,也可以不发出任何项目。
Observable 可以成功终止。
Observable 可能永远不会终止。例如,一个按钮可以被点击任意多次。
Observable 可能在任何时间点抛出错误。
订户
Observable 可以有多个订阅者。
当 Observable 发出一个项目时,每个订阅者的 onNext() 方法都会被调用。
当 Observable 完成发出项目时,每个订阅者的 onComplete() 方法都会被调用。
如果 Observable 发出错误,每个订阅者的 onError() 方法都会被调用。