Given the following handler snippet,
@Override public Mono<Void> handle(WebSocketSession session) { return session.send(Flux.error(new Throwable()) .onErrorResume(e -> session.close(CloseStatus.GOING_AWAY)) .then(Mono.empty())); }
when using ReactorHttpServer, the Mono from session#close never emit.