Working on an android app in kotlin. I need to set up a system to be able to do work from a live queue (and observe the results of the work in a stream). But I also have to be able to toggle the “queue processing” depending on a couple external factors (which also come in as streams) like networkI…
Tag: rx-android
Combine a list of Observables and wait until all completed
TL;DR How to convert Task.whenAll(List<Task>) into RxJava? My existing code uses Bolts to build up a list of asynchronous tasks and waits until all of those tasks finish before performing other steps. Essentially, it builds up a List<Task> and returns a single Task which is marked as completed whe…