引言
- 先补一下上文的有余
- doOnNext 很多小伙伴不是很了解,解释一下
doOnNext 通常用于后果解决之前的操作
比方,在网络申请收到返回值的时候,先验证一下返回值是否正确
比方,在收到数据时做一下缓存
比方,在收到状态码时做下判断
比方...
开篇
- 交火 Pro 侧重于嵌套类网络申请操作
-
次要实现性能
- 先获取所有的名字 -> 而后依据每个名字来获取对应个人信息
一. 疾速的写一下获取所有名字
- 先获取所有的名字 -> 而后依据每个名字来获取对应个人信息
API_Protocol1 API_protocol = retrofit_rx.create(API_Protocol1.class);
Subscription subscribe = API_protocol.getAllName()
.subscribeOn(Schedulers.newThread())// 申请在新的线程中执行
.observeOn(Schedulers.io()) // 申请实现后在 io 线程中执行
.observeOn(AndroidSchedulers.mainThread())// 最初在主线程中执行
.subscribe(new Action1<AllNameBean>() {
@Override
public void call(AllNameBean allNameBean) {LogUtils.e(allNameBean.getInfo());
}
});
二. 开始革新
- 先更正一处谬误
- 接口包装类须要改成上面的样子能力拜访到带名字的具体数据
- 因为我在后端接口中做了只容许 POST 办法读取参数,所以要用 Field 字段去提交数据
@FormUrlEncoded
@POST(Urls1.get_name_info)
Observable<NameInfoBean> getNamesInfo(@Field("name") String name);
革新核心思想
- 如果应用循环嵌套的话,整个代码会变得异样臃肿且不优雅
- 核心思想是应用 from 代替循环,而后用 flatMap 将每个名字变成另外一个网络申请
- 如果放弃最后的程序性 则应用 concatMap,用法雷同
- 而后对立在上游进行接管
三. 开始正餐
请看代码中的正文
API_Protocol1 API_protocol = retrofit_rx.create(API_Protocol1.class);
Subscription subscribe = API_protocol.getAllName()
.subscribeOn(Schedulers.newThread())// 申请在新的线程中执行
.observeOn(Schedulers.io()) // 申请实现后在 io 线程中执行
.subscribe(new Action1<AllNameBean>() {
@Override
public void call(AllNameBean allNameBean) {List<String> data = allNameBean.getData();
// 这里进行数组发送
Observable.from(data)
.subscribeOn(Schedulers.newThread()) // 申请在新的线程中执行
.observeOn(Schedulers.newThread())
.flatMap(new Func1<String, Observable<NameInfoBean>>() {
@Override
public Observable<NameInfoBean> call(String s) {LogUtils.e(s);
// 发送通过网络申请的个人信息数据
return API_protocol.getNamesInfo(s);
}
})
.observeOn(AndroidSchedulers.mainThread())// 最初在主线程中执行
.subscribe(new Action1<NameInfoBean>() {
@Override
public void call(NameInfoBean nameInfoBean) {LogUtils.e(nameInfoBean.getData().get 姓名());
LogUtils.e(nameInfoBean.getData().get 喜好());
}
});
}
});
总结
- 的确比写循环好,优雅的多
- 快些学起来呀
- 一起加油哇
RxJava 与 Retrofit 系列的文章就到这里完结了,接下来要写更多 Android 世界里的常识
喜爱的小伙伴请随时关注,新文章不会晚