内容简介:Android RxJava 实战系列:功能防抖
前言
-
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在
2s内,无论点击多少次,也只会发送1次网络请求
4. Demo地址
Carson_Ho的Github地址 = RxJava2实战系列:功能防抖
5. 总结
- 本文主要讲解了
Rxjava的实际开发需求场景:功能防抖需求 - 下面我将结合 实际场景应用 &
Rxjava的相关使用框架(如Retrofit、Eventbus) ,继续对Android中Rxjava的实际开发需求场景进行深入讲解 ,有兴趣可以继续关注 Carson_Ho的安卓开发笔记
请帮顶 / 评论点赞!因为你的鼓励是我写作的最大动力!
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Design Accessible Web Sites
Jeremy Sydik / Pragmatic Bookshelf / 2007-11-05 / USD 34.95
It's not a one-browser web anymore. You need to reach audiences that use cell phones, PDAs, game consoles, or other "alternative" browsers, as well as users with disabilities. Legal requirements for a......一起来看看 《Design Accessible Web Sites》 这本书的介绍吧!