Как обрабатывать исключения в Spring WebFlux и WebSocket

Question

Я разрабатываю веб-приложение, используя Spring WebFlux и Websockets. Я не могу понять, как бороться с исключениями. Я хотел бы вернуть сообщение об ошибке в случае возникновения исключения. Я пробовал onErrorReturn и onErrorResume, но соединение Websocket всегда закрывается. Может кто-нибудь помочь?

@Override
public Mono<Void> handle(WebSocketSession session) {
    return session.send(
            session.receive()
                    .map(WebSocketMessage::getPayloadAsText)
                    .map(this::toCommand)
                    .map(service::process)
                    .map(session::textMessage)
    );
}