具有更精确控制订阅动态的专业观察器。 首先我们有必要来了解一下什么是 Connectable Observable: 就是一种特殊的 Obser...

本页展示的操作符用于对整个序列执行算法操作或其它操作，由于这些操作必须等待数据发射完成（通常也必须缓存这些数据），它们对于非常长或者无限的序列来...

7.1 All 判定是否 Observable 发射的所有数据都满足某个条件。 传递一个谓词函数给 All 操作符，这个函数接受原始 Obser...

这个页面展示的操作符可用于组合多个 Observables。 Delay — 延时发射 Observable 的结果。DelaySubscrip...

很多操作符可用于对 Observable 发射的 onError 通知做出响应或者从错误中恢复，例如，你可以： 捕捉这个错误，切换到一个备用的 ...

这个页面展示的操作符可用于组合多个 Observables。 And/Then/When — 通过模式和计划组合多个 Observables 发...

这个页面展示的操作符可用于过滤和选择Observable发射的数据序列。Debounce — 仅在过了一段指定的时间还没发射数据时才发射一个数据...

RxJava2.0 操作符（1）—— Create 创建操作 Create 创建类操作符 Create — 使用一个函数从头创建一个 Obser...

场景：注册账号页面时，我们点击按钮发送验证码，在等待验证码时，界面会有倒计时提示，这此期间按钮不可点击。当倒计时结束时，按钮恢复。实现与功能都不...