Optimise optBinaryCodec#streamDecoder (#3237)

Co-authored-by: Nabil Abdel-Hafeez <[email protected]>
zio · Dec 24, 2024 · 47bb96a · 47bb96a
1 parent e6fa725
commit 47bb96a
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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