diff --git a/zio-http/jvm/src/main/scala/zio/http/netty/AsyncBodyReader.scala b/zio-http/jvm/src/main/scala/zio/http/netty/AsyncBodyReader.scala
index 709e74c7cb..3543fd17e4 100644
--- a/zio-http/jvm/src/main/scala/zio/http/netty/AsyncBodyReader.scala
+++ b/zio-http/jvm/src/main/scala/zio/http/netty/AsyncBodyReader.scala
@@ -118,7 +118,7 @@ private[netty] abstract class AsyncBodyReader extends SimpleChannelInboundHandle
           case State.Direct(callback)                                     =>
             // We're streaming, emit chunks as they come
             callback(Chunk.fromArray(content), isLast)
-            true
+            !isLast
         }
 
       if (readMore) ctx.read(): Unit