Browse Source

Merge pull request #469 from robymus/master

fix for issue #402, marking channel promise as success twice
master
Nikita Koksharov 8 years ago
committed by GitHub
parent
commit
ba26d0d702
  1. 4
      src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java

4
src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java

@ -227,7 +227,9 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter {
Queue<Packet> queue = msg.getClientHead().getPacketsQueue(msg.getTransport());
Packet packet = queue.poll();
if (packet == null) {
promise.trySuccess();
if (!promise.isDone()) {
promise.trySuccess();
}
break;
}

Loading…
Cancel
Save