相关疑难解决方法(0)

我正在玩RXJava,在Android中进行改造.我正在努力完成以下任务:

我需要定期轮询一个给我一个Observable的调用>(从这里我可以做到)

一旦我得到这个列表,我想迭代每个交付,并调用另一个方法,将给我ETA(所以只是更多信息)我想将这个新信息附加到交付,并返回完整列表与附加的额外信息每个物品.

一旦得到列表,我知道如何在没有rxjava的情况下做到这一点,但我想练习.

到目前为止这是我的代码:

pollDeliveries = Observable.interval(POLLING_INTERVAL, TimeUnit.SECONDS, Schedulers.from(AsyncTask.THREAD_POOL_EXECUTOR))
            .map(tick -> RestClient.getInstance().getApiService().getDeliveries())
                    .doOnError(err -> Log.e("MPB", "Error retrieving messages" + err))
                    .retry()
                    .subscribe(deliveries -> {
                        MainApp.getEventBus().postSticky(deliveries);
                    });

这给了我一份交货清单.现在我想完成第二部分.

希望我足够清楚.谢谢