java - 如何使用 Observable 在 RxJava 中测试 backPressure？

Question

我想了解 RxJava 中对 Flowable 的需求。所以我想用简单的 Observable 来处理大数据的 backPressure。但我没有得到任何错误。这是我的测试代码：

Observable.range(1, 10000).observeOn(Schedulers.computation())
        .subscribe(new Observer<Integer>() {

            @Override
            public void onSubscribe(@NonNull Disposable d) {

            }

            @Override
            public void onNext(@NonNull Integer integer) {
                System.out.println("next: " + integer);
            }

            @Override
            public void onError(@NonNull Throwable e) {
                System.out.println("onError " + e.toString());
            }

            @Override
            public void onComplete() {

            }

        });
try {
    Thread.sleep(10000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

如何使用 Observable 测试背压问题？谢谢