Как проверить backPressure в Rx Java, используя Observable? - PullRequest
1 голос
/ 16 февраля 2020

Я хочу понять необходимость Flowable в Rx Java. Поэтому я хочу иметь дело с backPressure для больших данных с помощью простого Observable. Но я не получаю никакой ошибки с этим. это мой тестовый код:

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();
}

Как я могу проверить проблемы backPressure с помощью Observable? Спасибо

...