From 74234cec750427a773cb5bcecbc831f3515c6340 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 6 Jan 2016 15:27:59 +0300 Subject: [PATCH] successful promise exception fixed. #302 --- .../com/corundumstudio/socketio/handler/EncoderHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java b/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java index 986568a..36bdbe5 100644 --- a/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java +++ b/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java @@ -221,7 +221,11 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter { } if (out.isReadable()) { - ctx.channel().writeAndFlush(res, promise); + if (!promise.isDone()) { + ctx.channel().writeAndFlush(res, promise); + } else { + ctx.channel().writeAndFlush(res); + } } else { promise.trySuccess(); out.release();