内容简介: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的安卓开发笔记
请帮顶 / 评论点赞!因为你的鼓励是我写作的最大动力!
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- struts实战--登录功能实现
- struts实战--添加功能(重点文件上传)
- 掌握SQL高级功能 !实战业务问题分析
- 「小程序JAVA实战」小程序搜索功能(54)
- HTML5拍照、摄像机功能实战
- 「小程序JAVA实战」小程序的关注功能(64)
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。