android - 多个顺序 Observable，每个 Observable 之间有时间延迟

Question

我正在尝试获取 google places并且根据 api 限制，每个请求不能超过 20 个位置，下一个请求需要 nextPageToken之前的请求。

问题:

• Zip运算符(operator)立即执行所有请求，但我需要它们按顺序及时延迟 4 seconds每个之间 Observable打电话

• Delay operator 允许 wait ，但实际上它会立即执行 Zip在给定的延迟时间后给我打电话并返回结果，这是不希望的。

我的来源:

LatLng some = new LatLng(31.471199, 74.234940);
Observable
        .zip(getNearByPlaces(some), getNearByPlaces(some), getNearByPlaces(some), new Func3<List<PlaceInfo>, List<PlaceInfo>, List<PlaceInfo>, List<PlaceInfo>>() {
            @Override
            public List<PlaceInfo> call(List<PlaceInfo> placeInfos, List<PlaceInfo> placeInfos2, List<PlaceInfo> placeInfos3) {
                placeInfos2.addAll(placeInfos3);
                placeInfos.addAll(placeInfos2);
                return placeInfos;
            }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<List<PlaceInfo>>() {
            @Override
            public void onCompleted() {
            }

            @Override
            public void onError(Throwable e) {
                e.printStackTrace();
            }

            @Override
            public void onNext(List<PlaceInfo> placeInfos) {
                adapter.setPlaces(placeInfos);
            }
        });

我是初学者，大约 1 周前开始使用 rxjava，所以您可以预料到错误。

Answer 1

假设您有以下响应模型

class Response {
    private String pageToken;
    private List<PlaceInfo> places;

    //setters, getters etc
}

而且您有两种使用 API 的方法

Observable<Response> getNearByPlaces(LatLng latLng) {...}
Observable<Response> getNextNearByPlaces(String pageToken) {...}

定义 Transformer 以获取额外的位置。它等待 4 秒，然后获取下一个位置并将源位置添加到响应中。

private Observable.Transformer<Response, Response> addNextPlaces() {
    return observable -> observable
            .delay(4, TimeUnit.SECONDS)
            .flatMap(sourceResponse -> getNextNearByPlaces(sourceResponse.getPageToken()),
                    ((sourceResponse, nextResponse) -> {
                        nextResponse.getPlaces().addAll(sourceResponse.getPlaces());
                        return responseNext;
                    }));
}

然后你就可以用这种方式做你需要的了

getNearByPlaces(latLng)
        .compose(addNextPlaces())
        //add here additional compose methods if you need them
        .subscribe(resultResponse -> {
            resultResponse.getPlaces() //handle result List
        }, error -> {
            //handle error
        });

附言注意线程。 delay 将 Scheduler 切换到 computation

附言我怀疑有一个更简单和优雅的解决方案:)