import io.reactivex.rxjava3.core.BackpressureStrategy;

import io.reactivex.rxjava3.core.Observable;

import io.reactivex.rxjava3.schedulers.Schedulers;

public class Ch8_11 {

public static void main(String[] args) {

Observable<Integer> source = Observable.range(1, 1000);

source.toFlowable(BackpressureStrategy.BUFFER)

.observeOn(Schedulers.io())

.subscribe(System.out::println);

sleep(10000);

}

private static void sleep(long millis) {

try {

Thread.sleep(millis);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}