在学习rxjava的过程中,有遇到过关于rxjava嵌套请求的例子,但是都是理想的状态的,每个请求都是顺利完成请求的.但是,现实是残酷的,我的第一个demo就挂掉了,因为手机没有联网.网友解释说,就好比一个水管,一头不通就不通了,但是程序偏偏不这么搞,你必须让我通,不通就挂掉!我去,这个坑搞大了,千辛万苦,终于搞通了,嵌套请求必须保持一个原则:一定让请求通畅 一定让请求通畅 一定让请求通畅 我的这个栗子的背景是:登录成功后,获取七牛的一些数据
public void login(View view) { final Api mApi = new Servise(MainActivity.this).Servise(); mApi.Login("136****3307", "123456").observeOn(Schedulers.newThread()).flatMap(new Function<Login, ObservableSource<ResponseBody>>() { @Override public ObservableSource<ResponseBody> apply(Login login) throws Exception { if (login.getResultCode() == 1) { return mApi.GetQiniu("" + login.getResultData().getUser().getId(), login.getResultData().getToken()); } else { return null; } } //此处是核心 }, new Function<Throwable, ObservableSource<ResponseBody>>() { @Override public ObservableSource<ResponseBody> apply(Throwable throwable) throws Exception { Toast.makeText(mContext, "链接网络失败", Toast.LENGTH_LONG).show(); return Observable.create(new ObservableOnSubscribe<ResponseBody>() { @Override public void subscribe(ObservableEmitter<ResponseBody> e) throws Exception { e.onNext(ResponseBody.create(MediaType.parse("text/xml"), "链接网络失败")); } }); } }, new Callable<ObservableSource<? extends ResponseBody>>() { @Override public ObservableSource<? extends ResponseBody> call() throws Exception { Toast.makeText(mContext, "链接网络失败", Toast.LENGTH_LONG).show(); return new ObservableSource<ResponseBody>() { @Override public void subscribe(Observer<? super ResponseBody> observer) { observer.onComplete(); } }; } }).observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io()).subscribe(new Consumer<ResponseBody>() { @Override public void accept(ResponseBody responseBody) throws Exception { Log.d("Text", responseBody.string()); } }); }我在代码标注的核心的地方的作用就是第一个网络访问异常的处理,只有重新创建一个被观察者,才能继续执行后面的subscribe()方法,如果我们不做任何处理的话,后面的所有逻辑就无法执行,程序当然挂掉拉!
