在不指定线程的情况下，RxJava遵循的是线程不变的原则，即：在调用subscribe()的线程生产事件；在生产事件的线程消费事件。如果需要切换线程，就需要用到Scheduler（调度器）。1)Scheduler的API(一)在RxJava中，Scheduler——调度器，相当于线程控制器，RxJava通过...

接上回继续，今天来学习下zip（打包)操作一、zip操作@TestpublicvoidzipTest(){Observable.zip(Observable.create(emitter->{for(inti=0;i<10;i++){emitter.onNext(100+i);}}),Observable....

上一篇已经熟悉了Observable的基本用法，但是如果仅仅只是“生产-消费”的模型，这就体现不出优势了，java有100种办法可以玩这个：）一、更简单的多线程正常情况下，生产者与消费者都在同一个线程里处理，参考下面的代码：finallongstart=System.currentTimeMil...

作为github上star数极高的响应式编程java扩展类库，rxjava是啥就不多说了，网上能查到一堆介绍，下面是一些学习记录：前提依赖：compile'io.reactivex.rxjava2:rxjava:2.1.9'一、Observable1.1helloworldrxjava中的核心思路是“生产者...

接入说明：项目中已集成RXjava，RXandroid。Retrofit，为避免包冲突，不须要再次接入。就可以直接使用RXjava，Retrofit的所有api.github地址：https://github.com/hunanqi/Retrofit_Two第一步：在项目的gradle文件里：allprojects{r...

离职在即，也没什么事情做，就鼓捣了一下。任意搭建了一个小框架，看看以后能不能搞出自己的一个model，好了。不说别的，上代码1，先上依赖库compile'io.reactivex:rxandroid:1.2.1'compile'com.squareup.okhttp3:okhttp:3.3.1&...

在Android6.0中，新添加了一个执行时的权限，我相信非常多人都已经知道了。预计也知道怎么用了，这篇博客非常easy。就是告诉大家怎样去申请执行时权限和RxPermission这个权限框架的使用。同一时候依据现有的技术封装思想，去封装一个自己可用的权限框架，好的，我们继续往下看关于AndroidM的更新变化，我就不...

 Subject可以看成是一个桥梁或者代理，在某些ReactiveX实现中（如RxJava），它同时充当了Observer和Observable的角色。因为它是一个Observer，它可以订阅一个或多个Observable；又因为它是一个Observable，它可以转发它收到(Observe)的数据，也可以发...