今天变动接口，发现新版的后端接口不能批量上传图片（以前接口可以扔一堆本地图片地址进去，然后统一返回一个list），只能单张图片上传，比较头大，并且图片数量是不确定的，用for循环遍历，调用上传接口的话，本地添加flag，每次返回一张就判断一次的话，到时能实现，但是这样做很蠢。
于是又去看了一下Rxjava的api文档，发现用fromIterable 操作符可以逐次发射list的中的数据，然后用flatmap转换一下，调用图片上传的接口，可以研究一下，于是实验一下：
List<String> resultString = new ArrayList<>();
Observable
.fromIterable(fileList)
.flatMap((Function<String, ObservableSource<BaseResModel<UploadFilesJavaResModel>>>) s -> {
MultipartBody.Builder builder = new MultipartBody.Builder().setType(MultipartBody.FORM);
File file = new File(s);
RequestBody body = RequestBody.create(MediaType.parse("application/octet-stream"), file);
//这里进行一些特定字段处理处理，每个项目可能不同就写了
MultipartBody multipartBody = builder.build();
return RetrofitFactory.getApi("上传图片").fileUpload(multipartBody);
})
.compose(TransformUtils.defaultSchedulers())
.subscribe(new Observer< String>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(String s) {
//在这里将每次返回的图片地址加到list中去
resultString.add(s);
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
// 当都有返回值的时候，在这里进行下一步操作
}
});
这样看上去功能能实现了，但是发现流程写死了，完全违背了RxJava变化莫测的灵活性，比如现在同时需要多个接口的返回值，才能进行下一步的操作，很多同学第一就想到用zip操作符，这很对，但是zip操作符，是操作的多个Observable，而刚刚写的已经进行subscribe操作了，失去了变换的可能性了。。。只能想别的办法了。。
有没有一种操作符可以合并fromIterable返回的结果呢？于是谷歌、百度、RxJava操作官方的API，果然发现了一个叫toList的操作符，toList()操作符的目的应该是将所有的数据放进一个List中去，等所有数据处理完毕后将这个List传递给这里的subscribe
那就有希望进行灵活变换了
但是在实际使用的时候，发现，toList操作符，返回的时一个Single，如果需要用zip操作符去合并多组的observable的时候，就不适用了。
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final Single<List<T>> toList() {
return toList(16);
}
只能继续看api和谷歌，又发现了一个神奇的操作符：flatMapObservable，大概的意思是对Single的数据执行flatMap操作，然后返回一个Observable：
public Observable<List<UploadFilesJavaResModel>> javaUploadFilesa(List<String> fileList, final String type) {
return Observable
.fromIterable(fileList)
.flatMap((Function<String, ObservableSource<BaseResModel<UploadFilesJavaResModel>>>) url -> {
MultipartBody.Builder builder = new MultipartBody.Builder().setType(MultipartBody.FORM);
File file = new File(url);
int index = url.lastIndexOf("/");
String fileName = url.substring(index + 1);
RequestBody body = RequestBody.create(MediaType.parse("application/octet-stream"), file);
//这里进行一些特定字段处理处理，每个项目可能不同就写了
MultipartBody multipartBody = builder.build();
return RetrofitFactory.getApi("上传图片").fileUpload(multipartBody);
})
//考虑一下上传失败的情况，抛出异常，在订阅里面处理
.map(uploadFilesResModelBaseResModel -> {
if (uploadFilesResModelBaseResModel.isSuccess()) {
return uploadFilesResModelBaseResModel.getData();
} else {
String errorMsg = "照片上传失败!";
throw new ApiException(errorMsg);
}
})
.toList()
.flatMapObservable(uploadFilesJavaResModels -> Observable.create(e -> {
e.onNext(uploadFilesJavaResModels);
e.onComplete();
}));
//toList下面用的是lambda表达式，如果看不懂，下面代码是没有用lambda表达式的原始代码（lambda表达式对于
//简化代码具有神奇的效果，但是由于省略了内部类，阅读起来有一定困难，特别是不熟悉api调用的情况下）
// .flatMapObservable(new Function<List<UploadFilesJavaResModel>, ObservableSource<List<UploadFilesJavaResModel>>>() {
// @Override
// public ObservableSource<List<UploadFilesJavaResModel>> apply(List<UploadFilesJavaResModel> list) throws Exception {
//
// return Observable.create(new ObservableOnSubscribe<List<UploadFilesJavaResModel>>() {
// @Override
// public void subscribe(ObservableEmitter<List<UploadFilesJavaResModel>> e) throws Exception {
// e.onNext(list);
// e.onComplete();
// }
// });
// }
// });
这样，就传入一个数组的图片，然后进行上传操作，返回的也是一系列图片在服务器上的地址~问题得到了解决。
RxJava还是非常强大的，操作符非常多，自己常用的也就那么几个，慢慢研究吧~~
