RxJava的使用

前言:一直看到Rxjava,但是一直没有研究,今天看了一下,做个整理。Rxjava由于其基于事件流的链式调用,逻辑简洁 ,使用简单的特点,深受各大 Android开发者的欢迎。

由于本人也是初次研究,就来总结一下基本的使用方法吧。

一:首先在主工程的build.gradle中导入基本的配置如下:

compile'io.reactivex.rxjava2:rxjava:2.1.0'

compile'io.reactivex.rxjava2:rxandroid:2.0.1'

二:先来看一下基本的流程

(1):首先创建被观察者Observable.代码如下.


(2)下面在来创建观察者Observer,代码如下:


(3)最后一步把观察者和被观察者关联起来:


打印出来的log如下:


从log中可以看出先是走了观察者的onSubscribe方法,继而走了观察者的subscribe方法,然后又回调了观察者的onNext方法,最后调用了观察者的onComplete方法。

三:合二为一 的链式流效果:


log如下所示:


从log上可以看出两次的效果是一样的。但是还是推荐后一种链式流的效果。

就是基础的效果,哈哈。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容