RxJava flatMap使用

1、使用场景
首先从一个接口中获取list,然后根据获取到list中的元素信息，再获取每个元素的详细信息
2、以下是代码片段（仅笔记于此）
String albumUrl = “http://m.kugou.com/zlist/list
?listid=2&type=0&uid=89255811
&sign=495dc043c2b3ac9f38e5f09d6d0bbef2
&_t=598024727&pagesize=100&json=&from=pcCode&page=1&share_type=collect”;
String musicPath = “D:\Music”; //表示存储路径
File file = new File(musicPath);
if (!file.exists()) {
file.mkdirs();
}
RxHttp.getInstance().getSyncServer()
.musicList(albumUrl)
.flatMap((Function<JSONObject, ObservableSource>) jsonObject -> {
List list = JSONObject.parseArray(jsonObject.getString(“info”), MusicItem.class);
return Observable.fromIterable(list);
})
.flatMap((Function<MusicItem, ObservableSource>) musicItem -> {
musicFile = new File(file.getAbsolutePath(), musicItem.getName() + “.mp3”);
return RxHttp.getInstance()
.getSyncServer()
.downloadMusic(musicItem);
})
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.subscribe(responseBody -> {
try {
InputStream is = responseBody.byteStream();
FileOutputStream fos = null;
fos = new FileOutputStream(musicFile);
BufferedInputStream bis = new BufferedInputStream(is);
byte[] buffer = new byte[1024];
int len;
while ((len = bis.read(buffer)) != -1) {
fos.write(buffer, 0, len);
}
fos.flush();
fos.close();
bis.close();
is.close();
} catch (IOException e) {
e.printStackTrace();
System.out.print(e.getMessage());
}
}, throwable -> {
System.out.print(throwable.getMessage());
});

RxJava flatMap使用相关推荐

RxJava flatMap操作符用法详解
RxJava系列文章目录导读: 一.RxJava create操作符的用法和源码分析二.RxJava map操作符用法详解三.RxJava flatMap操作符用法详解四.RxJava conc ...
RxJava flatMap，switchMap，concatMap
In this tutorial, we'll be looking into three important map operators in RxJava. FlatMap, SwitchMap, ...
RxJava（七）使用 debounce 操作符优化 App 搜索功能
RxJava 系列文章目录导读: 一.RxJava create 操作符的用法和源码分析二.RxJava map 操作符用法详解三.RxJava flatMap 操作符用法详解四.RxJava ...
RxJava 2.x 优秀学习资源
说明:本文主要是记录Rxjava 2.x 网上优秀博客链接,便于学习所用. Rxjava2.x GitHub链接 https://github.com/ReactiveX/RxJava RxAndr ...
Android 程序员的技术栈大全
AndroidAll 项目地址:chiclaim/AndroidAll 简介: Android 程序员的技术栈大全更多:作者提 Bug 标签: 内容涵盖绝大部分 Android 程序员所需要 ...
jenkins android md5,Jenkins配置自动打包 -- 遇到的坑
1.把gradle路径设为本地路径 Jenkins部署在远程linux服务器上,使用git将代码下载到服务器路径下后,无法使用gradle命令因为默认配置都是gradle同步时实时从网上下载,进入 ...
找到了一个非常好的安卓开发技术栈导航
最全的 Android 技术栈这个大佬写的非常好,并且整理了所有相关的知识和内容到github上,需要的盆友可以按照自己的需求去嫖.感谢大佬,后面会按照这个文章整理自己的不足,补齐短板知识点. 内容 ...
并发查询parallel_惯用并发：flatMap（）与parallel（）– RxJava常见问题解答
并发查询parallel 简单,有效和安全的并发是RxJava的设计原则之一. 然而,具有讽刺意味的是,它可能是该库中最容易被误解的方面之一. 让我们举一个简单的例子:假设我们有一堆UUID并且对于每 ...
flatMap（）与concatMap（）与concatMapEager（）– RxJava常见问题解答
RxJava 2.x中共有三个无缝相似的运算符: flatMap() , concatMap()和concatMapEager() . 它们都接受相同的参数-从原始流的单个项目到任意类型的(子)流的函 ...

RxJava flatMap使用

RxJava flatMap使用

RxJava flatMap使用相关推荐

最新文章

热门文章