Skip to content

Commit

Permalink
Reformat with scalafmt 3.8.6
Browse files Browse the repository at this point in the history
Executed command: scalafmt --non-interactive
  • Loading branch information
scala-steward authored and pjfanning committed Jan 29, 2025
1 parent e0e18f3 commit df553b7
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -100,8 +100,8 @@ object JacksonSupport extends JacksonSupport {
case "shared-concurrent-deque" => JsonRecyclerPools.sharedConcurrentDequePool()
case "bounded" =>
JsonRecyclerPools.newBoundedPool(cfg.getInt("buffer-recycler.bounded-pool-size"))
case "non-recycling" => JsonRecyclerPools.nonRecyclingPool()
case other => throw new IllegalArgumentException(s"Unknown recycler-pool: $other")
case "non-recycling" => JsonRecyclerPools.nonRecyclingPool()
case other => throw new IllegalArgumentException(s"Unknown recycler-pool: $other")
}

val defaultObjectMapper: ObjectMapper with ClassTagExtensions = createObjectMapper(jacksonConfig)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,12 +48,11 @@ final class UpickleCustomizationSupportSpec
import UpickleFoo._

"UpickleCustomizationSupport" should {
"support custom configuration" in {
Marshal(123)
.to[RequestEntity]
.flatMap(Unmarshal(_).to[String])
.map(_ shouldBe "foo")
}
"support custom configuration" in
Marshal(123)
.to[RequestEntity]
.flatMap(Unmarshal(_).to[String])
.map(_ shouldBe "foo")
}

override protected def afterAll() = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -103,12 +103,10 @@ trait ZioJsonSupport {
jd: JsonDecoder[A],
rt: zio.Runtime[Any]
): Unmarshaller[ByteString, A] =
Unmarshaller(_ =>
bs => {
val decoded = jd.decodeJsonStreamInput(ZStream.fromIterable(bs))
Unsafe.unsafeCompat(implicit u => rt.unsafe.runToFuture(decoded))
}
)
Unmarshaller { _ => bs =>
val decoded = jd.decodeJsonStreamInput(ZStream.fromIterable(bs))
Unsafe.unsafeCompat(implicit u => rt.unsafe.runToFuture(decoded))
}

/**
* `A` => HTTP entity
Expand Down

0 comments on commit df553b7

Please sign in to comment.