Read bytes when ready

rchodava · Apr 9, 2016 · 27f6aa9 · 27f6aa9
1 parent 86369b9
commit 27f6aa9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/core/src/main/java/org/chodavarapu/datamill/http/impl/ClientToServerChannelHandler.java b/core/src/main/java/org/chodavarapu/datamill/http/impl/ClientToServerChannelHandler.java
@@ -48,6 +48,11 @@ public void channelReadComplete(ChannelHandlerContext context) {
         context.flush();
     }
 
+    @Override
+    public void channelActive(ChannelHandlerContext context) throws Exception {
+        context.read();
+    }
+
     @Override
     public void channelRead(ChannelHandlerContext context, Object message) {
         if (message instanceof HttpRequest) {
@@ -88,6 +93,8 @@ public void channelRead(ChannelHandlerContext context, Object message) {
                 entityStream.onCompleted();
             }
         }
+
+        context.read();
     }
 
     private void processRequest(ChannelHandlerContext context, HttpRequest originalRequest) {