Spring Webflux не выдает исключение в методе onNext подписчика - PullRequest
Новая
       67

Spring Webflux не выдает исключение в методе onNext подписчика

0 голосов
/ 19 апреля 2020

Я учусь с Spring Webflux и пытаюсь понять, почему метод onNext подписчика не выдает ошибку. 

Subscriber<Employee> employeeSubscriber = new Subscriber<Employee>(){
.. onSubscribe(Subscription s){
s.request(10);
}
.. onNext(Employee emp){
throw new RuntimeException(“testing exception”);
}
.. onError(Throwable t){
log.error(“Exception: {}, e.getMessage());
}
...
}
employeeMono.subscribe(employeeSubscriber);

Выше не выдает никаких исключений RuntimeException. Но приведенный ниже код вызывает ошибку: 

Mono.just(employee).subscribe(throw new RuntimeException(“testing exception”));

Может кто-нибудь, пожалуйста, объясните, почему исключение не генерируется в первом сценарии, а генерируется во втором.

Кроме того, как добиться исключения в методе onNext Абонента!

Спасибо!

...