Talk Android吧第五百三十四回RxJava的观察者
各位看官们大家好,上一回中咱们说的例子是"RxJava中断事件流",本章回中介绍的例子是" RxJava的观察者"。闲话休提,言归正转,让我们一起Talk Android吧!
概念介绍
我们在前面章回中介绍RxJava的用法时使用Observer
接口的对象当充当观察者,本章回中再介绍另外一种观察者:Consumer
接口.
该接口可以当作Observer接口的轻量级接口。因为创建该接口的对象时只需要重写一个方法就可以,在数量上比Consumer接口的四个方法要少。这也是我们称它轻量的原因。
使用方法
创建Consumer
接口的对象,并且实现其中的accept
()方法,示例代码如下:
Consumer<String> consumer = new Consumer<String>() {
@Override
public void accept(String s) throws Throwable {
Log.d(TAG, "consumer accept: " s);
}
};
该接口使用了泛型,可以接受正常的事件类型,比如上面代码中的String类,或者Exception类,也可以接受用户自己定义的事件类型。因此该接口既可以用来处理正常事件也可以用来处理异常事件。如果要同时处理正常和异常两种事件,那么就需要创建两个接口对象。
创建完接口对象后使用subscribe
()方法就可以把观察者和被观察者绑定在一起。顺便说一下,subscribe
()方法是重载方法,可以接受一个或者两个Consumer接口对象,该方法的原型如下:
public final Disposable subscribe(@NonNull Consumer<? super T> onNext) {}
public final Disposable subscribe(@NonNull Consumer<? super T> onNext, @NonNull Consumer<? super Throwable> onError) {}
public final Disposable subscribe(@NonNull Consumer<? super T> onNext, @NonNull Consumer<? super Throwable> onError,
@NonNull Action onComplete) {}
我们可以使用Consumer接口对象来模拟Observer
接口:
创建两个对象,一个用来处理正常事件流(onNext
),另外一个用来处理异常事件流(onError
)。其实大家可以从subscribe
()方法的参数名称中看出来。在实际使用中,我们可以依据项目需要灵活创建一个或者两个Consumer接口对象来观察事件流。
示例代码
Consumer<String> consumer = new Consumer<String>() {
@Override
public void accept(String s) throws Throwable {
Log.d(TAG, "consumer accept: " s);
}
};
Consumer<Throwable> consumerException = new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Throwable {
Log.d(TAG, "consumerException accept: exception." throwable.toString());
}
};
Action onCompleteAction = new Action() {
@Override
public void run() throws Throwable {
Log.d(TAG, "onCompleteAction run: ");
}
};
//只关心正常事件
observable.subscribe(consumer);
//同时关心正常和异常这两种事件
observable.subscribe(consumer,consumerException);
//同时关心正常,异常和完成这三种事件
observable.subscribe(consumer,consumerException,onCompleteAction);
我们在代码中演示了使用一个和两个Consumer接口对象的方法,编译并且运行上面的程序,可以得到以下结果:
- 正常流程:
consumer accept: Event 1
consumer accept: Event 2
consumer accept: Event 3
onCompleteAction run:
- 异常流程:
consumer accept: Event 1
consumer accept: Event 2
consumerException accept: exception.java.lang.Exception: error
注意:如果异常发生后Consumer对象会捕获到异常并且中断事件流,并且忽略异常后面的其它事件,这点和Observer接口的处理方式一样。
看官们,关于"RxJava中的观察者"的例子咱们就介绍到这里,欲知后面还有什么例子,且听下回分解!
这篇好文章是转载于:学新通技术网
- 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
- 本站站名: 学新通技术网
- 本文地址: /boutique/detail/tanhgfkckj
-
photoshop保存的图片太大微信发不了怎么办
PHP中文网 06-15 -
《学习通》视频自动暂停处理方法
HelloWorld317 07-05 -
Android 11 保存文件到外部存储,并分享文件
Luke 10-12 -
word里面弄一个表格后上面的标题会跑到下面怎么办
PHP中文网 06-20 -
photoshop扩展功能面板显示灰色怎么办
PHP中文网 06-14 -
微信公众号没有声音提示怎么办
PHP中文网 03-31 -
excel下划线不显示怎么办
PHP中文网 06-23 -
excel打印预览压线压字怎么办
PHP中文网 06-22 -
TikTok加速器哪个好免费的TK加速器推荐
TK小达人 10-01 -
怎样阻止微信小程序自动打开
PHP中文网 06-13