正文
前言
-
Rxjava
,由于其
基于事件流的链式调用、逻辑简洁 & 使用简单
的特点,深受各大
Android
开发者的欢迎。
如果还不了解RxJava,请看文章:
Android:这是一篇 清晰 & 易懂的Rxjava 入门教程
-
RxJava
如此受欢迎的原因,在于其
提供了丰富 & 功能强大的操作符,几乎能完成所有的功能需求
-
今天,我将为大家带来
Rxjava
创建操作符的
常见开发应用场景:功能防抖需求
,并结合
Retrofit
与
RxJava
实现,希望大家会喜欢。
-
本系列文章主要基于
Rxjava 2.0
-
接下来的时间,
我将持续推出
Android
中
Rxjava 2.0
的一系列文章,包括原理、操作符、应用场景、背压等等
,有兴趣可以继续关注
Carson_Ho的安卓开发笔记
!!
目录
1. 需求场景
2. 功能说明
注:关于
Rxjava
中的
throttleFirst()
操作符的使用请看文章:
Android RxJava:过滤操作符 全面讲解
3. 具体实现
// 注册控件
Button button;
button = (Button)findViewById(R.id.button);
/*
* 1. 此处采用了RxBinding:RxView.clicks(button) = 对控件点击进行监听,需要引入依赖:compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0'
* 2. 传入Button控件,点击时,都会发送数据事件(但由于使用了throttleFirst()操作符,所以只会发送该段时间内的第1次点击事件)
**/
RxView.clicks(button)
.throttleFirst(2, TimeUnit.SECONDS) // 才发送 2s内第1次点击按钮的事件
.subscribe(new Observer<Object>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Object value) {
Log.d(TAG, "发送了网络请求" );
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "对Error事件作出响应" + e.toString());
// 获取异常错误信息
}
@Override
public void onComplete() {
Log.d(TAG, "对Complete事件作出响应");
}
});
-
测试结果
在
2s
内,无论点击多少次,也只会发送1次网络请求
4. Demo地址
Carson_Ho的Github地址 = RxJava2实战系列:功能防抖
5. 总结
-
本文主要讲解了
Rxjava
的实际开发需求场景:功能防抖需求
-
下面我将结合
实际场景应用 &
Rxjava
的相关使用框架(如
Retrofit
、
Eventbus
)
,继续对
Android
中
Rxjava
的实际开发需求场景进行深入讲解 ,有兴趣可以继续关注
Carson_Ho的安卓开发笔记
请点赞!因为你的鼓励是我写作的最大动力!
相关文章阅读