RxJava的map

转载请标明出处http://77blogs.com/?p=175

map的作用:对Observable发射的数据都应用一个函数,然后再发射最后的结果集。最后map()方法返回一个新的Observable。

举个例子:

 

首先遍历集合中的每一个项,然后给map进行映射更改,每一项都加一,然后再转换为集合,然后再将该集合传入map中,在map中加入新的项4,最后给观察者的回调方法,输出该集合。

打印的log为:

12-23 21:46:36.691 3072-3102/com.status.rxjavasample D/RxJavaHelper: [4]

中间可以有多个map操作符。

.map(new Function<Integer, Integer>(){}中的Function里面的泛型参数,第一个是指输入的类型,第二个是指输出的类型。

再看下面这个例子:

输出的log为:

12-30 21:45:25.713 32565-32611/com.status.rxjavasample D/RxJavaHelper: 1
12-30 21:45:25.713 32565-32611/com.status.rxjavasample D/RxJavaHelper: 2
12-30 21:45:25.713 32565-32611/com.status.rxjavasample D/RxJavaHelper: 3

发布者

大道苍莽,一笔一墨,皆重之。

发表回复