Fix mistake for client body streaming

zio · Sep 30, 2024 · 4bff266 · 4bff266
1 parent ff4e642
commit 4bff266
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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