您的位置：首页 > 移动开发 > Android开发

Android RxJava 实战系列：功能防抖

2018-01-22 09:33 302 查看

前言

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事件作出响应");
}
});

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
测试结果

在

2s

内，无论点击多少次，也只会发送1次网络请求

4. Demo地址

Carson_Ho的Github地址 = RxJava2实战系列：功能防抖

5. 总结

本文主要讲解了

Rxjava

的实际开发需求场景：功能防抖需求
下面我将结合实际场景应用 &
Rxjava
的相关使用框架（如
Retrofit
、
Eventbus
），继续对

Android

中

Rxjava

的实际开发需求场景进行深入讲解
，有兴趣可以继续关注Carson_Ho的安卓开发笔记

请帮顶 / 评论点赞！因为你的鼓励是我写作的最大动力！

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航