红帽白皮书新鲜出炉!点击获取,让你的云战略更胜一筹! 了解详情
写点什么

从案例学 RxAndroid 开发(下)

  • 2016-04-07
  • 本文字数:2936 字

    阅读完需:约 10 分钟

欢迎回来!看来你想更多的了解 RxJava。如果你还没有看第一部分 (此处链接有待修改),推荐先看第一篇。现在我们来看其他几个例子。再说一遍,所有的例子都可以在这个 repo 里找到。在每个例子的开始,我都会说明代码是属于哪个 Activity 的。 案例 4:Subjects

现在我们写一个 Activity ,里面要展示一个数字并有一个自增按钮。在看代码之前,先介绍另一个有关 RxJava 的概念,Subject。Subject 这个对象既是 Observable 又是 Observer,我会把 Subject 想象成一个管道:从一端把数据注入,结果就会从另一端输出。

Subject 有好几类,在这里我们使用最简单的:PublishSubject。使用 PublishSubject 时,一旦数据从一端注入,结果会立即从另一端输出。

首先我们要写这个管道的输出端。刚才说了 Subject 也是 Observable,也就是说我们可以像观察任何一个 Observable 一样观察它。这段代码的功能就是观察管道的输出端到底输出了什么。我们在这里写一个很简单的 Observer 来更新 mCounterDisplay 控件。

复制代码
mCounterEmitter = PublishSubject.create();
mCounterEmitter.subscribe(new Observer<Integer>() {
@Override
public void onCompleted() { }
@Override
public void onError(Throwable e) { }
@Override
public void onNext(Integer integer) {
mCounterDisplay.setText(String.valueOf(integer));
}
});

与第一部分中的例子不同,在这个例子中 onNext() 会被调用多次。每次发送新的数据时,mCounterDisplay 都会展示新的数据。但是 PublishSubject 怎么发送数据呢?让我们看一下 mIncrementButton 的监听代码。

复制代码
mIncrementButton.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
mCounter++;
mCounterEmitter.onNext(mCounter);
}
});

可以看到 mIncrementButton 在 onClick() 回调方法中做了两件事情:

  1. 让 mCounter 变量自增。
  2. 调用 mCounterEmitter 的 onNext() 方法并传入 mCounter。

由于 Subject 同时也是 Observer,所以它也有 onNext() 方法,因此我们可以通过调用 onNext() 方法把数据注入管道的输入端,可以理解为同我们在一端中观察自增按钮是否被点击,然后把信息告知管道另一端的 Observer。 案例 5:Map()

我们现在要写一个只显示一个数字的 Activity 。这将是一个很简单的 Activity,因为我们要在这里使用 map 方法。如果你接触过函数式编程,你可能对 map 并不陌生。你可以把 map 当做一个方法,它接收一个数据,然后输出另一个数据,当然输入输出的两个数据之间是有联系的。

我们先写一个只发送一个数字 4 的 Single 对象。

复制代码
Single.just(4).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return String.valueOf(integer);
}
}).subscribe(new SingleSubscriber<String>() {
@Override
public void onSuccess(String value) {
mValueDisplay.setText(value);
}
@Override
public void onError(Throwable error) { }
});

我们最终要显示 Single 所发送的数据,但首先我们需要将这个数据从 Integer 转为 String,而这里的解决方法就是使用 map() 函数。正如刚才所说,map 接收一个数据,进行处理而后输出它,这正是我们需要的。现在 Single 会发送数字 4,我们使用 map() 方法将其转为 String,而后交给 Observer 去展示它。

这个例子中对于 map 方法的使用很轻量,不过 map 可是非常强大的,在下一个例子中你可以看到,map 可以被用来执行任意代码,在处理数据方面起到很重要的作用。 案例 6:综合使用

现在我们要写一个用来根据名字搜索城市的 Activity 。在这个 Activity 中,我们要使用在这两篇文章中所学的所有知识并写一个比较大的例子。同时还要介绍一个新的概念:deboundce。开始。

现在我们要写一个 PublishSubject,并能接收用书输入进输入框的数据,而后根据输入获取符合的列表,并展示。

复制代码
mTextWatchSubscription = mSearchResultsSubject
.debounce(400, TimeUnit.MILLISECONDS)
.observeOn(Schedulers.io())
.map(new Func1<String, List<String>>() {
@Override
public List<String> call(String s) {
return mRestClient.searchForCity(s);
}
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<List<String>>() {
@Override
public void onCompleted() { }
@Override
public void onError(Throwable e) { }
@Override
public void onNext(List<String> cities) {
handleSearchResults(cities);
}
});
mSearchInput.addTextChangedListener(new TextWatcher() {
@Override
public void beforeTextChanged(CharSequence s, int start, int count, int after) { }
@Override
public void onTextChanged(CharSequence s, int start, int before, int count) {
mSearchResultsSubject.onNext(s.toString());
}
@Override
public void afterTextChanged(Editable s) { }
});

这段代码有不少内容,让我们一点一点分析。

首先你会看到 debounce() 方法。这是啥?有啥用?如果你看一下我们是如何给输入框添加监听器的,你会发现每当输入的内容改变时都会有输入发送到 mSearchResultsSubject,不过我们不想让用户每点一个键都向服务器请求一次。我们想等一会,等用户停止输入(代表差不多输完)的时候再请求服务器。

而 debounce() 方法就是做这个的。这个方法告诉 mSearchResultsSubject 在没有数据传入达 400 毫秒时才发送数据。意思就是,仅当用户 400ms 都没有改变输入内容时,Subject 才会发送最新的搜索字符串。这样以来我们就不会进行无意义的网络请求了,UI 也不会每输入一个字符都更新。

我们想通过 RestClient 来访问服务器,而因为 RestClient 涉及 IO 操作,我们需要在 IO Scheduler 中进行这个操作,所以要写 observeOn(Schedulers.io())。

好了,现在我们会把搜索字段发送到 IO Scheduler 中,在这里 map 就要发挥作用了,我们在 map 方法中通过关键字获取搜索结果的列表。在 map 中我们可以调用任意外部方法,在这里使用 RestClient 获取搜索结果。

因为 map 方法会在 IO Scheduler 中运行,而我们又要用其返回值填充 View,所以要重新切换到 UI 线程,所以要写 observeOn(AndroidSchedulers.mainThread())。现在搜索结果会被发送到 UI 线程。要注意两个 observeOn() 方法的顺序,这一点至关重要。现在我们总结一下数据发送的顺序。

复制代码
mSearchResultsSubject
|
|
V
debounce
|||
|||
V
map
|
|
V
observer

一个竖杠代表数据在 UI 线程中发送,三个竖杠代表数据在 IO Scheduler 中发送。

最终,我们获得搜索结果,并展示给用户。 结语

有关 RxJava 就说这么多了,希望这两篇文章能帮你了解 RxJava 的基础。强烈建议你自己探索有关 RxJava 的其他方面。如果你有问题或者只是想说点什么,欢迎在下方留言。

2016-04-07 17:243776

评论

发布
暂无评论
发现更多内容

“互联网+”大学生创新创业大赛来了,欢迎报名龙蜥社区赛题!

OpenAnolis小助手

开源 操作系统 互联网+ 龙蜥社区 大学生创新创业大赛

vue-表单输入绑定

小恺

6月月更

测试进阶必备,这5款http接口自动化测试工具不要太香~

伤心的辣条

Python 程序人生 软件测试 自动化测试 接口自动化测试

@开发者 云端一条生产线,让软件开发更敏捷、更安全

华为云开发者联盟

云计算 敏捷 华为云 devcloud

瀑布式项目管理软件测评!

PingCode

API 网关 Apache APISIX 助力雪球双活架构演进

API7.ai 技术团队

zookeeper 投资 网关 APISIX APISIX Summit

基于 Apache APISIX 的自动化运维平台

API7.ai 技术团队

自动化运维 APISIX 网关 APISIX Summit

SRE,了解一下?35+岁程序员新选择

华为云开发者联盟

SRE 华为云

JDK7 HashMap如何实现?

源字节1号

软件开发 前端开发 后端开发 小程序开发

大数据平台迁移实践 | Apache DolphinScheduler 在当贝大数据环境中的应用

Apache DolphinScheduler

Apache 大数据 开源 DolphinScheduler workflow

python简介

左手の明天

Python Python解释器

要想自助洗车加盟赚钱记住这几点

共享电单车厂家

自助洗车加盟 自助洗车品牌

开启全方位安全巡检

观测云

自助洗车市场悄然兴起你准备好了吗

共享电单车厂家

自助洗车 自助洗车加盟

华为云重磅发布:“乐高式”自动驾驶研发开放平台,携手伙伴共建生态

华为云开发者联盟

自动驾驶 云计算 华为云

Curve 进入 CNCF Sandbox,完善统一云原生开源存储拼图

网易数帆

开源 分布式 云原生 存储 cncf

如何修改 Rancher v2.6 的 Rancher Server IP 地址

Rancher

Kubernetes k8s rancher

FutureTask

急需上岸的小谢

6月月更

融云 x 川航: 为民航通信安上“即时之翼”

融云 RongCloud

为什么都认为confluence非常好,好在哪里

PingCode

首批 | 腾讯云完成国内首个云原生安全成熟度评估

腾讯安全云鼎实验室

云原生

自助洗车机洗车怎么收费和付费

共享电单车厂家

自助洗车加盟 自助洗车收费 自助洗车付费

使用 Amazon EC2 降低 DeepRacer 的训练成本 DeepRacer-for-cloud 的实践操作

亚马逊云科技 (Amazon Web Services)

Amazon EC2 EC2

SQL和Python 哪个更容易自学?

Jackpop

低代码开发:企业应用构建新模式

力软低代码开发平台

10段实用Python代码,帮我省了几万块钱!

Jackpop

共享自助洗车机让你告别传统洗车

共享电单车厂家

共享自助洗车 自助洗车加盟

24H共享便民自助洗车加盟怎么样

共享电单车厂家

共享自助洗车 自助洗车加盟 24小时自助洗车 便民自助洗车

如何系统地学习 C++ 语言?太全面了!

Jackpop

阿里云 MSE 基于 Apache APISIX 的全链路灰度方案实践

API7.ai 技术团队

阿里云 MSE APISIX 网关 全链路灰度

APISIX 助力中东社交软件,实现本地化部署

API7.ai 技术团队

API网关 社交软件 APISIX Summit

从案例学RxAndroid开发(下)_Java_Kurtis Nusbaum_InfoQ精选文章