我在我的项目中使用Rxjava和Retrofit2.0,它看起来像这样:
Observable<List<A>> getAFromServer();
Observable<List<B>> getBFromServer(@Body A.a);
Run Code Online (Sandbox Code Playgroud)
如果我不使用反应方式,它将是这样的:
List<A> listA = getAFromServer();
foreach(A a: listA){
getBFromServer(a.a)
}
Run Code Online (Sandbox Code Playgroud)
所以,我的问题是如何使用Rxjava来实现这个以及使用什么运算符?