Я хочу понять необходимость 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? Спасибо