Spring Webflux Websocket在onErrorResume逻辑可以完成之前关闭

import org.springframework.web.reactive.socket.WebSocketHandler;
import org.springframework.web.reactive.socket.WebSocketSession;
import reactor.core.publisher.Mono;

public class MyWebSocketHandler implements WebSocketHandler {

    @Override
    public Mono<Void> handle(WebSocketSession session) {
        return session.send(
            session.receive()
                .map(message -> {
                    // 处理接收到的消息
                    return message.getPayloadAsText();
                })
                .doOnError(throwable -> {
                    // 处理异常
                    System.err.println("Error processing message: " + throwable.getMessage());
                })
                .onErrorResume(throwable -> {
                    // 恢复操作
                    if (session.isOpen()) {
                        return session.send(
                            session.textMessage("Error occurred: " + throwable.getMessage())
                        );
                    } else {
                        return Mono.empty();
                    }
                })
        ).andWriteWith(Mono.empty())
          .doOnTerminate(() -> {
              // 连接关闭时释放资源
              System.out.println("WebSocket connection closed");
          });
    }
}