diff --git a/build.sbt b/build.sbt index 9c5eb056d..a0cd9881c 100644 --- a/build.sbt +++ b/build.sbt @@ -32,7 +32,7 @@ lazy val scalaNativeSettings = Def.settings( Test / envVars ++= Map("S2N_DONT_MLOCK" -> "1") ) -val Scala212 = "2.12.19" +val Scala212 = "2.12.20" val Scala213 = "2.13.15" ThisBuild / crossScalaVersions := Seq(Scala213, "3.3.4") ThisBuild / scalaVersion := Scala213 // the default Scala diff --git a/sdk-exporter/common/src/main/scala/org/typelevel/otel4s/sdk/exporter/otlp/grpc/GrpcCodecs.scala b/sdk-exporter/common/src/main/scala/org/typelevel/otel4s/sdk/exporter/otlp/grpc/GrpcCodecs.scala index f2ca65e30..65756cbbb 100644 --- a/sdk-exporter/common/src/main/scala/org/typelevel/otel4s/sdk/exporter/otlp/grpc/GrpcCodecs.scala +++ b/sdk-exporter/common/src/main/scala/org/typelevel/otel4s/sdk/exporter/otlp/grpc/GrpcCodecs.scala @@ -47,7 +47,7 @@ private[otlp] object GrpcCodecs { } } - _.through(lpmDecoder).through(decompress).through(entityDecoder) + s => s.through(lpmDecoder).through(decompress).through(entityDecoder) } def encode[F[_]: RaiseThrowable: Compression, A]( @@ -63,12 +63,13 @@ private[otlp] object GrpcCodecs { val lpmEncoder: Pipe[F, LengthPrefixedMessage, Byte] = StreamEncoder.once(LengthPrefixedMessage.codec).toPipeByte - _.through(entityEncoder) - .through(compression) - .chunks - .foldMonoid - .map(chunks => LengthPrefixedMessage(gzip, chunks.toByteVector)) - .through(lpmEncoder) + s => + s.through(entityEncoder) + .through(compression) + .chunks + .foldMonoid + .map(chunks => LengthPrefixedMessage(gzip, chunks.toByteVector)) + .through(lpmEncoder) } }