RxJava - 获取 2 个组合请求的结果数据列表

Question

我有这两个服务：

private Observable<UMapsResponse> requestToServiceGetMaps(int idVenue, String accessToken) {
    return mService.getUMaps(idVenue, accessToken);
}

 private Observable<UMap> requestToServiceGetMapImageUrl(int idVenue, int idMap, String accessToken) {
    return mService.getUMap(idVenue, idMap, accessToken);
}

所以我像这样结合了我的两个服务：

    requestToServiceGetMaps(idVenue, accessToken)
            .flatMap(uMapsResponse -> Observable.just(uMapsResponse.getIndoorMaps()))
            .flatMapIterable(indoorMap -> indoorMap)
            .flatMap(
                    indoorMap -> requestToServiceGetMapImageUrl(idVenue, indoorMap.getId(), accessToken),
                    (indoorMap, uMap) -> Log.i(TAG, "MapsItem: " + new MapsItem(indoorMap, uMap))
            ).toList()
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new SingleObserver<List<Integer>>() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onSuccess(List<Integer> integers) {

                }

                @Override
                public void onError(Throwable e) {

                }
            });

所以我有两个问题：

1. 为什么我在 onSuccess 方法中有整数列表？
2. 如何获取 MapsItem 列表（indoorMap、uMap）？

Answer 1

您会得到一个 Integer 列表，因为您从观察者链的最后一步发出 Integer，因为这是 Log.i() 返回的内容。

            ...
            .flatMap(
                    indoorMap -> requestToServiceGetMapImageUrl(idVenue, indoorMap.getId(), accessToken),
                    (indoorMap, uMap) -> new MapsItem(indoorMap, uMap)
            )
            .doOnNext( v -> Log.i(TAG, "MapsItem: " + v) )
            .toList()
            ...

请注意，最终 flatMap() 的结果是您要查找的新 MapsItem。