RxJava Backpressure

Backpressure.java

ConnectableFlowable<Integer> pub = Flowable.range(1, 10000)
                .publish();

pub.debounce(1, SECONDS)
    .subscribeOn(computation())
    .subscribe(new DefaultSubscriber<Integer>() {
        @Override
        public void onStart() {
            request(1);
        }

        @Override
        public void onComplete() {
            System.out.println("Done.");
        }

        @Override
        public void onError(Throwable e) {
            System.err.println("Oh shit!");
            e.printStackTrace();
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println(String.format("slow: %d on thread: %s",
                integer, Thread.currentThread().getName()));
            request(1);
        }
    });

pub.subscribe(x -> System.out.println(String.format("fast: %d on thread: %s",
    x, Thread.currentThread().getName())));

pub.connect();

Thread.sleep(5 * 60 * 1000);