利用Rxjava简单处理复杂请求利用Rxjava简单处理复杂请求

这是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都看不懂，多难过啊），下面分析。最后上代码，有兴趣的可以看看。
【利用Rxjava简单处理复杂请求】先看效果图
screen 这个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, List, CommonResult, 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,Single,Single合成Single返回，便于后续处理。
getAnswers返回Single>，说到flatmap就想到和map的区别，map是将一个值转化为另一个值，但是flatmap是将一个值转化为一个新的Observable或者Single，再发出去，相当于解决嵌套的问题。下面有个注意点，用questionId去请求问题接口的话，如果把多个questionId放一起，用

隔开去请求就会得到一个多个问题的数组返回

private fun getAnswers(): Single> { 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的使用。代码写的还有很多不足的地方，欢迎提出。