Estou brincando com o RXJava, adaptado no Android. Estou tentando fazer o seguinte:

Preciso pesquisar periodicamente uma chamada que me dê um Observable> (A partir daqui eu poderia fazer isso)

Depois de obter essa lista, quero iterar em cada Entrega e chamar outros métodos que me fornecerão o ETA (apenas mais informações). Quero anexar essas novas informações à entrega e devolver a lista completa com as informações extras anexadas a cada item.

Sei como fazê-lo sem o rxjava depois de obter a lista, mas gostaria de praticar.

Este é o meu código até agora:

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);
                    });

Isso está me dando uma lista de entregas. Agora eu gostaria de realizar a segunda parte.

Espero ter sido suficientemente claro. obrigado