import io.reactivex.rxjava3.core.Flowable;

import io.reactivex.rxjava3.schedulers.Schedulers;

import java.util.concurrent.TimeUnit;

public class Ch8_15 {

public static void main(String[] args) {

Flowable.interval(1, TimeUnit.MILLISECONDS)

.onBackpressureLatest()

.observeOn(Schedulers.io())

.subscribe(i -> {

sleep(5);

System.out.println(i);

});

sleep(5000);

}

private static void sleep(long millis) {

try {

Thread.sleep(millis);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}