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 networkIsAvailable
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 when all tasks in the list complete, as per the example on