前言
Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。
Github截图
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);
RxView.clicks(button)
.throttleFirst(2, TimeUnit.SECONDS) // 才发送 2s内第1次点击按钮的事件
.subscribe(new Observer() {
@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地址
5. 总结
本文主要讲解了 Rxjava的实际开发需求场景：功能防抖需求
下面我将结合 实际场景应用 & Rxjava的相关使用框架(如Retrofit、Eventbus) ，继续对 Android中 Rxjava 的实际开发需求场景进行深入讲解 ，感兴趣的同学可以继续关注本人运营的Wechat Public Account：
请点赞！因为你的鼓励是我写作的最大动力！
不定期分享关于安卓开发的干货，追求短、平、快，但却不缺深度。