Как Spring WebFlux обрабатывает ошибки в Flux/Mono пайплайне?

Middle
257 просмотров
AFK Offer AI

onErrorReturn возвращает дефолтное значение при ошибке. onErrorResume переключается на другой Mono/Flux — fallback. onErrorMap трансформирует одно исключение в другое. doOnError выполняет side effect (логирование) не прерывая propagation. retry/retryWhen для автоматических ретраев. Важно: ошибки в реактивном пайплайне propagate как onError сигнал, subscriber получает их в Subscriber.onError() или через block() — бросается как исключение.

Следующий вопрос

Реализуйте пул потоков (простой ThreadPool) с BlockingQueue