RxAndroid:合并多个呼叫



我从RxAndroid开始,并希望通过它的API和Retrofit列出图像。

改造接口:

public interface ImageApi {
    @GET("image")
    Observable<ImageDto> getImage(@Query("id") final Integer id);
}

在这里我得到一个对象:

public void getImage(final Integer id, final Observer<ImageDto> observer) {
    imageApi.getImage(id)
            .subscribeOn(Schedulers.newThread())
            .subscribe(observer);
}

获取列表图像的方法比我想象的要复杂得多。在这种情况下,得到一个元素的列表:

public void getImages(final List<Integer> ids, final Observer<List<ImageDto>> observer) {
    Observable.from(ids).flatMap(new Func1<Integer, Observable<ImageDto>>() {
        @Override
        public Observable<ImageDto> call(Integer id) {
            return imageApi.getImage(id);
        }
}).toList().subscribeOn(Schedulers.newThread()).subscribe(observer);

了解我应该使用:

Observable.zip

但我无法意识到如何。有人可以帮助我吗?

代码是正确的。我犯了一个错误,列表中只有一个 id。解决。

最新更新