RxJava & RxAndroid简单使用（4）

这里就简单的介绍RxJava的 变换 操作

map()

和

flatMap()

，RxJava1.0和RxJava2.0 的传进去的参数有点不同，1.0传进去的是一个

Func1

，而2.0传进去的是一个

Function

。变换 有一个相同点：它也是把传入的参数转化之后返回另一个对象，不同的是：

map()

返回的是一个

Object

对象，而

flatMap()

返回的是

Observable

对象

map()

Observable.just(1,2,3)
.map(new Function<Integer, String>() {
@Override
public String apply(Integer integer) throws Exception {
return integer+"";
}
})//map返回的是一个Object
.subscribe(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {

}

@Override
public void onNext(String value) {
Log.d("--->onNext",value);
}

@Override
public void onError(Throwable e) {

}

@Override
public void onComplete() {

}
});

flatMap()

Observable.just(1,2,3)
.flatMap(new Function<Integer, ObservableSource<String>>() {
@Override
public ObservableSource<String> apply(Integer integer) throws Exception {
return Observable.just(integer+"");
}
})//map返回的是一个Observable
.subscribe(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {

}

@Override
public void onNext(String value) {
Log.d("--->onNext",value);
}

@Override
public void onError(Throwable e) {

}

@Override
public void onComplete() {

}
});

结合Scheduler切换线程操作

Observable.just(1,2,3)// 在IO线程操作，由 subscribeOn() 指定
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.map(new Function<Integer, String>() {
@Override
public String apply(Integer integer) throws Exception {
return "map1:"+integer;
}
}) // 在新线程操作，由 observeOn() 指定
.observeOn(Schedulers.io())
.map(new Function<String, String>() {
@Override
public String apply(String s) throws Exception {
return "map2:"+s;
}
})// 在IO线程操作，由 observeOn() 指定
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {

}

@Override
public void onNext(String value) {
Log.d("--->onNext",value);
}

@Override
public void onError(Throwable e) {

}

@Override
public void onComplete() {

}
});// 在Android主线程操作，由 observeOn() 指定