From a9e0aae4da42c38699a746978aef5e2ba84b3f7b Mon Sep 17 00:00:00 2001 From: Robert Elek Date: Wed, 9 Aug 2017 15:15:52 +0700 Subject: [PATCH] fix for issue #402, marking channel promise as success twice --- .../com/corundumstudio/socketio/handler/EncoderHandler.java | 4 +++- 1 file changed, 3 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 bd063d8..3f124cd 100644 --- a/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java +++ b/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java @@ -227,7 +227,9 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter { Queue queue = msg.getClientHead().getPacketsQueue(msg.getTransport()); Packet packet = queue.poll(); if (packet == null) { - promise.trySuccess(); + if (!promise.isDone()) { + promise.trySuccess(); + } break; }