map 操作符 map 操作符，对 Observable 发射的每一项数据应用一个函数，执行变换操作，然后返回一个变换后结果的 Observable。map 操作符默认不在任何特定的调度器上执行。 private void mapClick() { new Thread() { @Override public void run() { ...

Error handling 相关的操作符来集中统一地处理错误。RxJava 中错误处理的操作符为 Catch 和 Retry Retry retry 的意思就是试着重来，当原始 Observable 发射 onError 通知时，retry 操作符不会让 onError 通知传递给观察者，它会重新订阅这个 Observable 一次或者多次 (意味着重新从头发射数据)，所以可能造成数据...

zip 操作符 zip 操作符介绍 zip 组合事件的过程就是分别从发射器 A 和发射器 B 各取出一个事件来组合，并且一个事件只能被使用一次，组合的顺序是严格按照事件发送的顺序来进行的； 最终接收器收到的事件数量是和发送器发送事件最少的那个发送器的发送事件数目相同。 zip 总结 zip 默认在同一个线程，getStringObservable 发送完毕后，getInt...

创建型操作符 操作符 作用 create 使用一个函数从头创建一个 Observable just 将一个或多个对象转换成发射这个或这些对象的一个 Observable from 将一个 Iterable、...

timeout 如果原始 Observable 过了指定的一段时长没有发射任何数据，Timeout 操作符会以一个 onError 通知终止这个 Observable，或者继续一个备用的 Observable。 RxJava 中的实现的 Timeout 操作符有好几个变体： 1. timeout(long,TimeUnit)： 第一个变体接受一个时长参数，每当原始Observabl...

RxJava 线程调度 调度器分类 RxJava 使用 subscribeOn、observeOn 和 onNext 的时候可以改变和切换线程，它们都是按顺序执行的，不是并发执行，至多也就切换到另外一个线程，如果它中间的操作是阻塞的，久会影响整个 Rx 的执行 调度器类型 作用 Schedulers....

RxJava 什么是 RxJava？ 一个在 JVM 上使用可观测的序列来组成异步的、基于事件的程序的库。举个例子说明：下载一张照片，用户点击下载，弹出正在下载提示框，下载结束显示图片，关闭提示框。用 RxJava 实现简洁。和观察者模式对比：观察者设计模式，起点是被观察者，终点是观察者，一条流水线的思维，响应式编程. RxJava 原理？ 构建链的阶段 subscribe...

RxJava 注意 Observable.just()、fromIterable() 的局限性 代码执行过早 使用 Observable.just() 即使你没有调用 subscribe 方法。just() 括号里面的代码也已经执行了。显然，Observable.just() 不适合封装网络数据，因为我们通常不想在 subscribe 之前做网络请求。同理，fromIterable 也...

RxLifecycle RxJava 通过线程调度器更容易控制和切换线程，种种优点，使用它的人也越来越多。但是使用不好，很容易导致内存泄露。用来严格控制由于发布了一个订阅后，由于没有及时取消，导致 Activity/Fragment 无法销毁导致的内存泄露。 引入 // RxLifecycle基础库 compile 'com.trello.rxlifecycle2:rxlifecycl...

RxJava2 应用场景 18 个 RxJava2 应用场景https://github.com/kaushikgopal/RxJava-Android-Samples RxJava 应用场景https://blog.csdn.net/johnny901114/article/details/51568562 RxJava1.x 使用场景小结 - 大头鬼https://blo...