java flatmap使用,rxjava2.0第三篇之flatMap使用
标签：
flatMap 方法：
public final Observable flatMap(Function super T, ? extends ObservableSource extends R>> mapper) {
return flatMap(mapper, false);
}
flatmap 和 map 的区别：
从底层方法中可以看出，两个方法返回值都是Observable；
不同点在于他们的Function接口中，flatmap输出的是一个ObservaleSource 对象，而map方法输出的是一个任意值
使用环境：
注册成功后马上调用登录接口进行自动登录
代码示例：
注册后登陆的案例，案例中的path要换位自己的path
1.1 工具方法(注意)
注意，以下三个方法为工具方法
public static Observable getObservable(final String path) {
return Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(@NonNull ObservableEmitter e) throws Exception {
OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
Request request = new Request.Builder().url("http://192.168.1.66:8080/manager/" + path).build();
Response response = okHttpClient.newCall(request).execute();
e.onNext(response);
}
}).subscribeOn(Schedulers.io());
}
public static Observable getObservableTwo() {
return Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(@NonNull ObservableEmitter e) {
e.onNext("发送第一个");
e.onNext("发送第二个");
}
}).subscribeOn(Schedulers.io());
}
public static Observable getObservableThere() {
return Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(@NonNull ObservableEmitter e) {
e.onNext("我是第三个发射器，就只发送一个");
}
}).subscribeOn(Schedulers.io());
}
1.2 flatmap方法使用
getObservable("json.json") 为注册时候的请求，getObservable("two.json")为登陆时候的请求；
public static void flatMap(final TextView textView) {
getObservable("json.json").observeOn(AndroidSchedulers.mainThread())
.doOnNext(new Consumer() {
@Override
public void accept(@NonNull Response response) throws Exception {
// Log.e("------->",response.body().string());
}
}).observeOn(Schedulers.io()) //指定接收器所在的线程
//flatmap，获取上游返回值，根据当前返回值来判断，是否是注册成功了
.flatMap(new Function>() {
@Override
public Observable apply(@NonNull Response response) throws Exception {
//如果注册status状态为200，那么接着登陆
if (new JSONObject(response.body().string()).get("status").equals("200")) {
return getObservable("two.json");
} else { //如果状态值不为200就返回null，或者其他值，这个由您自己定夺
return null;
}
}
}).observeOn(AndroidSchedulers.mainThread()) //切回主线程，可以update UI
.subscribe(new Consumer() { //对登陆状态进行处理
@Override
public void accept(@NonNull Response response) throws Exception {
textView.setText(response.body().string() + "-----");
}
});
}
标签：
来源： https://blog.csdn.net/mwthe/article/details/82775433