map
/**
* 可以将转换成另外一种数据类型
*/
private void map() {
Observable
.just(12)
.map(integer -> "经过map转换后的数据:"+integer)
.subscribe(s -> content.setText(s));
} #### flatMap
/**
* 将一个发射数据的Observable变换为多个Observables,然后将它们发射的数据合并后放进一个单独的Observable
*/
private void flatMap() {
Observable
.just(12)
.flatMap(integer -> Observable.just("经过flatMap转换后的数据:"+integer))
.subscribe(s -> content.setText(s));
} 注:concatMap的使用和flatMap类似,区别在于 新生成的事件,flatMap是无序的,而concatMap是有序的(按照原始发送数据事件的顺序)