Skip to content

Commit

Permalink
Update Scala 2.12 to 2.12.20
Browse files Browse the repository at this point in the history
  • Loading branch information
iRevive committed Oct 11, 2024
1 parent 62e5df6 commit cfeeb8a
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
2 changes: 1 addition & 1 deletion build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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](
Expand All @@ -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)
}

}

0 comments on commit cfeeb8a

Please sign in to comment.