From 20607b3e302e52007f4bb0092c879c55796ace71 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Mon, 12 Jan 2015 21:15:42 +0300
Subject: [PATCH] websocket buffer release fixed. #191

---
 .../com/corundumstudio/socketio/handler/EncoderHandler.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java b/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java
index b9fa451..c101d60 100644
--- a/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java
+++ b/src/main/java/com/corundumstudio/socketio/handler/EncoderHandler.java
@@ -217,8 +217,9 @@ public class EncoderHandler extends ChannelOutboundHandlerAdapter {
             if (log.isTraceEnabled()) {
                 log.trace("Out message: {} sessionId: {}", out.toString(CharsetUtil.UTF_8), msg.getSessionId());
             }
-            ctx.channel().writeAndFlush(res);
-            if (!out.isReadable()) {
+            if (out.isReadable()) {
+                ctx.channel().writeAndFlush(res);
+            } else {
                 out.release();
             }