这是Android Weekly第270期推荐的一篇文章：How to make complex requests simple with RxJava in Kotlin，Kotlin写的，MVP+Dagger2+RxJava2+Retrofit2，现在的标配。下载下来发现作者是用Android Studio 3.0写的，改build.gradle中的gradle版本也跑不起来，也不想下载beta版的AS，就想着自己试着写一个，顺便练习下。MVP和Dagger2其实挺烦人的，所以我就怎么简单怎么写，达到目的就行了，还是用的Kotlin写的（如果你说你不会kotlin，那么建议赶紧学学，说不定以后大牛的Demo都看不懂，多难过啊），下面分析。最后上代码，有兴趣的可以看看。
先看效果图
这个Demo主要用的StackOverflow的开放API，就2个页面，第一个界面是请求了reputation最高的用户并展示，第二个页面是选择了该用户，展示其提的问题，给别人回答的答案，最喜欢的问题这三个部分，每个部分只显示3条。
烦人的就是第二个页面了，该页面是由4个接口返回的值组成的，其中getQuestions和getFavorites可以直接获取到，但是getAnswers返回的是答案，我们还要通过答案中的question_id再去请求对应的问题来展示。
一般的做法就是一个一个请求，再写个方法组成没问题，但是用RxJava中的flatmap和zip操作符能够更加轻松的完成。
首先考虑用Single,对于Single，官网是这样解释的：
A Single is something like an Observable, but instead of emitting a series of values — anywhere from none at all to an infinite number — it always either emits one value or an error notification.
区别于Observable不同的是，Observable发出0～n个事件，而single只发出一个（事件）值：成功的值或者失败的提示，我们就关心这2样，相比较Observable的onNext,onComplete,onError稍微简单些。
Single.zip(
ApiHelper.getService().getQuestionsByUser(mUserId),
getAnswers(),
ApiHelper.getService().getFavoritesByUser(mUserId),
Function3<CommonResult<Question>, List<Question>, CommonResult<Question>, DetailModel>
{ questionResult, answers, favoritesResult ->
val questions = questionResult.items.take(3)
val favorites = favoritesResult.items.take(3)
DetailModel(questions, answers, favorites)
}
).subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
adapter.setData(it)
}, {
it.printStackTrace()
toast("请求错误：${it.message}")
})
zip的作用是将前三个Single发射的东西整合成一个再发射出去，看Function3，比如上面是将Single<Questions>,Single<Answers>,Single<Favorites>合成Single<DetailModel>返回，便于后续处理。
getAnswers返回Single<List<Question>>，说到flatmap就想到和map的区别，map是将一个值转化为另一个值，但是flatmap是将一个值转化为一个新的Observable或者Single，再发出去，相当于解决嵌套的问题。下面有个注意点，用questionId去请求问题接口的话，如果把多个questionId放一起，用;隔开去请求就会得到一个多个问题的数组返回
private fun getAnswers(): Single<List<Question>> {
return ApiHelper.getService()
.getAnswersByUser(mUserId)
.flatMap {
val processedAnswers = it.items
.filter { it.accept }
.take(3)
val ids = processedAnswers
.map { it.questionId.toString() }
.joinToString(separator = ";")
ApiHelper.getService()
.getQuestionById(ids)
.map { it.items }
}
}
最后上自己写的代码地址：GitHub Repository，主要核心还是上面的zip和flatmap的使用。代码写的还有很多不足的地方，欢迎提出。
