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

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

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

接上回继续，今天来学习下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中的核心思路是“生产者...

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