File tree Expand file tree Collapse file tree
src/main/kotlin/net/ccbluex/netty/http/websocket Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1919 */
2020package net.ccbluex.netty.http.websocket
2121
22+ import io.netty.channel.ChannelFutureListener
2223import io.netty.channel.ChannelHandlerContext
2324import io.netty.channel.ChannelInboundHandlerAdapter
2425import io.netty.handler.codec.http.websocketx.*
@@ -48,8 +49,9 @@ internal class WebSocketHandler(private val server: HttpServer) : ChannelInbound
4849 is PingWebSocketFrame -> ctx.channel().writeAndFlush(PongWebSocketFrame (msg.content().retain()))
4950 is CloseWebSocketFrame -> {
5051 // Accept close frame and send close frame back
51- ctx.channel().writeAndFlush(msg.retainedDuplicate())
52- ctx.channel().close().sync()
52+ ctx.channel()
53+ .writeAndFlush(msg.retainedDuplicate())
54+ .addListener(ChannelFutureListener .CLOSE )
5355
5456 server.webSocketController.removeContext(ctx)
5557 logger.debug(" WebSocket closed due to ${msg.reasonText()} (${msg.statusCode()} )" )
You can’t perform that action at this time.
0 commit comments