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.
Hello. I need a multithreading processing for my collection. I tried to
ExecutorService threadPoolExecutor = Executors.newFixedThreadPool(coreCount);
Observable<Observable<N>> source, that emit as many
coreCount. For each new Observable do
Or may be there is some operator for that task?