successful promise exception fixed. #302

9 years ago · 74234cec75
1 changed files with 5 additions and 1 deletions
--- 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();