Ich spiele mit RXJava rum, rüste es in Android nach. Ich versuche Folgendes zu erreichen:

Ich muss regelmäßig einen Anruf abfragen, der mir ein Observable gibt> (von hier aus konnte ich es tun)

obald ich diese Liste erhalte, möchte ich sie in jeder Lieferung wiederholen und eine andere Methode aufrufen, mit der ich die ETA erhalte (also nur weitere Informationen). Ich möchte diese neuen Informationen in die Lieferung aufnehmen und die vollständige Liste mit den angehängten zusätzlichen Informationen zurückgeben zu jedem Gegenstand.

Ich weiß, wie man das ohne rxjava macht, wenn ich die Liste habe, aber ich würde gerne üben.

Dies ist mein Code bisher:

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

Dies gibt mir eine Liste der Lieferungen. Jetzt möchte ich den zweiten Teil durchführen.

Hoffentlich war ich klar genug. Vielen Dan