0
我有api从服务器下载单个mp3文件,这是使用RxJava作为波纹管消耗的。RxAndroid下载多个文件,最多3个并发线程
Observable<ResponseBody> observable = audioService.getFile(fileNameWithExtension);
observable.subscribeOn(Schedulers.newThread())
.observeOn(Schedulers.newThread())
.subscribe(someCallBackClass<ResponseBody>);
这只是下载单个文件,回调将文件保存在磁盘上。 我想下载文件列表,将每个文件保存在磁盘上,并等待所有下载完成,最多3个调用应该并行执行。 如何用RXAndroid做到这一点,我尝试了flatmap,但我无法完全理解它。
编辑新代码
List<Observable<Response<ResponseBody>>> audioFiles = new ArrayList<>();
for (String fileNameWithExtension : fileNamesWithExtension) {
Observable<Response<ResponseBody>> observable = restFactory.getAudioService().getFile(fileNameWithExtension);
audioFiles.add(observable);
}
Observable.from(audioFiles).flatMap(audioFile -> Observable.fromCallable(() -> {
audioFile.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.toBlocking()
.subscribe(new CallBackWithErrorHandling<>(Downloader.this));
return 0;
}).subscribeOn(Schedulers.io()), MAX_CONCURRENT)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
goToMainActivity();
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "Something went wrong , " + Thread.currentThread().getName());
Log.e(TAG, "Something went wrong , " + e.toString());
showToast(R.string.something_went_wrong);
goToMainActivity();
}
@Override
public void onNext(Integer integer) {
}
});
,这是工作的罚款,但是当网络出现故障或互联网连接速度较慢我得到
java.lang.RuntimeException: Can't create handler inside thread that has not called Looper.prepare()
我无法了解哪些线正好需要observeOn() android主线程。