RxJava—变换操作符

Posted by dingqiang.l on August 15, 2018

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是有序的(按照原始发送数据事件的顺序)