摘要:回顾在上一节的使用一基本用法中,介绍了的基本用法。它同样只有一个方法,这个方法也无返回值,但有一个参数与同理,由于和也是单参数无返回值的,因此可以将和打包起来传入以实现不完整定义的回调的使用定义三个对象,分别打包。
回顾
在上一节Android RxJava的使用(一)基本用法中,介绍了RxJava的基本用法。下面来回顾下实现一次RxJava的基本使用。
例:分别打印"Hello"、" World"
Observable.just("Hello", "World") .subscribe(new Subscriber() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(String s) { Log.i(TAG, s); } });
可以看到,我们这里只用了onNext(obj),还有两个重写的onError(error)和onCompleted()并没有用到,这样导致我们多出了几行根本用不到的代码。于是就想能不能只写我们使用到的,其他几个没用到的就不写,这样的代码看着才舒服。接下来就是使用本次的主角Action来代替Subscriber
Action上部分的代码使用Action来代替Subscriber得到的代码是这样的:
Observable.just("Hello", "World") .subscribe(new Action1() { @Override public void call(String s) { Log.i(TAG, s); } });
舒服多了有没有!!
什么是Action
Action是RxJava 的一个接口,常用的有Action0和Action1。
Action0: 它只有一个方法 call(),这个方法是无参无返回值的;由于 onCompleted() 方法也是无参无返回值的,因此 Action0 可以被当成一个包装对象,将 onCompleted() 的内容打包起来将自己作为一个参数传入 subscribe() 以实现不完整定义的回调。
Ation1:它同样只有一个方法 call(T param),这个方法也无返回值,但有一个参数;与 Action0 同理,由于 onNext(T obj) 和 onError(Throwable error) 也是单参数无返回值的,因此 Action1 可以将 onNext(obj)和 onError(error) 打包起来传入 subscribe() 以实现不完整定义的回调
Action的使用
定义三个对象,分别打包onNext(obj)、onError(error) 、onCompleted()。
Observable observable = Observable.just("Hello", "World"); //处理onNext()中的内容 Action1onNextAction = new Action1 () { @Override public void call(String s) { Log.i(TAG, s); } }; //处理onError()中的内容 Action1 onErrorAction = new Action1 () { @Override public void call(Throwable throwable) { } }; //处理onCompleted()中的内容 Action0 onCompletedAction = new Action0() { @Override public void call() { Log.i(TAG, "Completed"); } };
接下来使用subscribe重载的方法
//使用 onNextAction 来定义 onNext() Observable.just("Hello", "World").subscribe(onNextAction); //使用 onNextAction 和 onErrorAction 来定义 onNext() 和 onError() Observable.just("Hello", "World").subscribe(onNextAction, onErrorAction); //使用 onNextAction、 onErrorAction 和 onCompletedAction 来定义 onNext()、 onError() 和 onCompleted() Observable.just("Hello", "World").subscribe(onNextAction, onErrorAction, onCompletedAction);
根据实际情况使用以上的方法处理onNext(obj)、onError(error) 、onCompleted()的回调。
现在有个疑问,为什么使用Action也能达到使用Subscriber的结果?进subscribe(Action1 onNext)的源码看看。
还以为有多高深,原来就是把Action对象转化成对应的Subscriber对象了。这样就不难理解为什么可以使用Action来代替Subscriber了。
重新写打印"Hello"、" Wrod"的方法
Observable.just("Hello", "Wrold").subscribe(new Action1() { @Override public void call(String s) { Log.i(TAG, s); } });
相比第一篇那冗长的代码,现在感觉怎么样?还是觉得代码多?确实,如果只是打印几个字符串确实还是略微复杂。不急,RxJava还有其他功能呢。
小结Action的使用为我们减少了不必要的代码,使得写出的代码看上去更加得简洁。不过就目前来看RxJava还是没有什么优势值得我们去使用,下一篇我还会介绍更多RxJava的用法。慢慢得,你就会发现使用RxJava写出来的代码看上去真的很漂亮。
更多:
更多:
Android RxJava的使用(三)转换(map、flatMap)
Android RxJava的使用(四)线程控制 —— Scheduler
以上有错误之处感谢指出
参考:给 Android 开发者的 RxJava 详解
(本文部分内容引用自该博客)
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/73399.html
摘要:前两篇的使用一基本用法的使用二介绍了的基本用法,对还不了解的请先看以上两篇。这篇为大家讲解中和的使用。注意对这些发射的数据做的是合并操作,因此它们可能是交错的。如果要保证顺的的话,可以使用。其他操作符除了和之外,还有其他操作符以供使用。 前两篇Android RxJava的使用(一)基本用法、Android RxJava的使用(二)Action介绍了RxJava的基本用法,对Rxjav...
摘要:观察者模式面向的需求是对象观察者对对象被观察者的某种变化高度敏感,需要在变化的一瞬间做出反应。规定,当不会再有新的发出时,需要触发方法作为标志。在事件处理过程中出异常时,会被触发,同时队列自动终止,不允许再有事件发出。 我从去年开始使用 RxJava ,到现在一年多了。今年加入了 Flipboard 后,看到 Flipboard 的 Android 项目也在使用 RxJava ,并且使...
阅读 1152·2023-04-26 02:38
阅读 1412·2021-11-22 09:34
阅读 1140·2021-09-26 10:19
阅读 3066·2019-08-29 17:15
阅读 3476·2019-08-29 12:27
阅读 1648·2019-08-26 13:51
阅读 1831·2019-08-26 13:47
阅读 979·2019-08-26 12:20