diff --git a/zio-http/shared/src/main/scala/zio/http/codec/HttpContentCodec.scala b/zio-http/shared/src/main/scala/zio/http/codec/HttpContentCodec.scala
index 916742b9e9..e846225e5a 100644
--- a/zio-http/shared/src/main/scala/zio/http/codec/HttpContentCodec.scala
+++ b/zio-http/shared/src/main/scala/zio/http/codec/HttpContentCodec.scala
@@ -172,7 +172,7 @@ sealed trait HttpContentCodec[A] { self =>
       else bc.decode(bytes).map(Some(_))
 
     override def streamDecoder: ZPipeline[Any, DecodeError, Byte, Option[A]] =
-      ZPipeline.chunks[Byte].map(bc.decode).map(_.toOption)
+      ZPipeline.chunks[Byte].map(bc.decode(_).toOption)
 
     override def streamEncoder: ZPipeline[Any, Nothing, Option[A], Byte] =
       ZPipeline.identity[Option[A]].map(_.fold(Chunk.empty[Byte])(bc.encode)).flattenChunks