These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
flatMap(Func1<T, Observable<R>> f, int maxConcurrent)works?
flatMapsignature with maxConcurrent of, say, 100 ensure that no more than 100 invocations of the map function are made at a time?
range) to swamp my io layer with too many requests in an instant
Observable.range(1, 1000) .map(id -> buildUrlToResource(id)) //driver can only cope with around 150 asynchronous requests .flatMap(url -> driver.fireRequestAsync(url), 100) .doOnNext(response -> showNotification(response.content()) .toBlocking().last(); //wait for last response