Как обрабатывать исключения в реактивном коде?

В реактивном программировании (например, с использованием Project Reactor или RxJava) обработка исключений отличается от традиционного подхода. Вместо try-catch используется специальный оператор для обработки ошибок в потоке данных.

Основные способы обработки ошибок:

• onErrorReturn — возвращает запасное значение при ошибке.
• onErrorResume — переключается на другой поток при ошибке.
• retry — повторяет подписку при ошибке определённое число раз.
• doOnError — позволяет выполнить побочные действия при ошибке (логирование и т.п.).

Пример на Reactor:

Flux.just(1, 2, 0, 4)
    .map(i -> 10 / i) // при i=0 будет ArithmeticException
    .onErrorResume(e -> Flux.just(-1)) // при ошибке возвращаем поток с -1
    .subscribe(System.out::println);

Таким образом, ошибки не выбрасываются наружу, а обрабатываются внутри реактивного потока, что позволяет сохранять асинхронность и непрерывность обработки данных.