import io.reactivex.rxjava3.core.Flowable;

import io.reactivex.rxjava3.schedulers.Schedulers;

import java.util.concurrent.ThreadLocalRandom;

public class Ch8_17 {

public static void main(String[] args) {

randomGenerator(1, 10000)

.subscribeOn(Schedulers.computation())

.doOnNext(i -> System.out.println("Emitting " + i))

.observeOn(Schedulers.io())

.subscribe(i -> {

sleep(50);

System.out.println("Received " + i);

});

sleep(10000);

}

static Flowable<Integer> randomGenerator(int min, int max) {

return Flowable.generate(emitter ->

emitter.onNext(ThreadLocalRandom.current().nextInt(min, max))

);

}

private static void sleep(long millis) {

try {

Thread.sleep(millis);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}