版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/mwthe/article/details/82775433
flatMap 方法:
public final <R> Observable<R> flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper) {
return flatMap(mapper, false);
}
flatmap 和 map 的区别:
共同点:返回一个Observable
不同点:
在于他们的Function接口中,flatmap输出的是一个 ObservaleSource 类型对象,而map方法输出的是一个任意类型的,没有像 flatmap 方法中 指明要继承 ObservaleSource;
map方法:该Observable对 源ObservableSource 发出的每个项应用指定函数,并发送这些函数应用程序的结果。
flatmap方法:该ObservableSource基于对 源ObservableSource发出的每个项 应用您提供的函数来发出项,其中该函数返回一个ObservableSource,然后 合并所得到 的ObservableSources并 发出合并的结果。
使用环境 之一:
注册成功后马上调用登录接口进行自动登录
代码示例:
注册后登陆的案例,案例中的path要换位自己的path
1.1 工具方法(注意)
注意,以下方法为工具方法,接下来rxjava系列中会一直使用
public static Observable getObservable(final String path) {
return Observable.create(new ObservableOnSubscribe<Response>() {
@Override
public void subscribe(@NonNull ObservableEmitter<Response> 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<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) {
e.onNext("发送第一个");
e.onNext("发送第二个");
}
}).subscribeOn(Schedulers.io());
}
public static Observable getObservableThere() {
return Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> 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<Response>() {
@Override
public void accept(@NonNull Response response) throws Exception {
// Log.e("------->",response.body().string());
}
}).observeOn(Schedulers.io()) //指定接收器所在的线程
//flatmap,获取上游返回值,根据当前返回值来判断,是否是注册成功了
.flatMap(new Function<Response, Observable<String>>() {
@Override
public Observable<String> 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<Response>() { //对登陆状态进行处理
@Override
public void accept(@NonNull Response response) throws Exception {
textView.setText(response.body().string() + "-----");
}
});
}