1.doOnSubscribe是事件被订阅之前(也就是事件源发起之前)会调用的方法，这个方法一般用于修改、添加或者删除事件源的数据流。2.doOnNext是观察者被通知之前(也就是回调之前)会调用的方法，说白了就是最终回调之前的前一个回调方法，这个方法一般做的事件类似于观察者做的事情，只是自己不是最终的回调者。（观察者...

//compose：对Observabl进行变换，加工处理Observable.just(1,2,3,4,5).compose(newObservableTransformer<T,T>(){@OverridepublicObservableSource<T>apply(Observable&l...

Subject：它既是Observable，又是observer。也就是既可以发送事件，也可以接收事件。下面是四个子类PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的区别：PublishSubject<Integer>source=Publ...

publicclassRxSearchObservable{publicstaticObservable<String>fromView(SearchViewsearchView){　　　　　　//Subject的理解看这里https://www.cnblogs.com/yongfengnice/p/102...

 ...

第一步:添加依赖:compile'io.reactivex:rxandroid:1.2.0'compile'com.squareup.retrofit2:adapter-rxjava:2.1.0'compile'com.squareup.retrofit2:converter-gson:2.1.0'compile'co...

在前面已经初步封装了一个MVP的网络请求框架，那只是个雏形，还有很多功能不完善，现在进一步进行封装。添加了网络请求时的等待框，retrofit中添加了日志打印拦截器，添加了token拦截器，并且对DataManager类进行了扩展，真正体现它的作用，并且对大量的重复代码做了一定封装，减少代码的冗余。下面结合上篇文章，进...

更多文章请点击链接：http://77blogs.com/?p=162转载请标明出处：https://www.cnblogs.com/tangZH/p/12088300.html，http://77blogs.com/?p=162 RxJava究竟是啥，从根本上来讲，它就是一个实现异步操作的库，并且能够使代码...

 在不指定线程的情况下，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...

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