赞
踩
flatMap 方法:
- public final <R> Observable<R> flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper) {
- return flatMap(mapper, false);
- }
flatmap 和 map 的区别:
共同点:返回一个Observable
不同点:
map(Function<? super T, ? extends R> mapper) 的参数是两个泛形的;
flatMap(Function<? super T, ? extends ObservableSource<? extends R>> mapper) 第二个参数是指定继承ObservableSource的
map返回的是结果集 ,flatmap返回的是包含结果集的Observable;
map被订阅时每传递一个事件执行一次onNext方法,flatmap多用于多对多,一对多,再被转化为多个时,一般利用from/just进行一一分发;
代码示例:
注册后登陆的案例,案例中的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() + "-----");
- }
- });
- }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。