diff --git a/pekko-http-jackson/src/main/scala/com/github/pjfanning/pekkohttpjackson/JacksonSupport.scala b/pekko-http-jackson/src/main/scala/com/github/pjfanning/pekkohttpjackson/JacksonSupport.scala index 42657ba..8731efe 100644 --- a/pekko-http-jackson/src/main/scala/com/github/pjfanning/pekkohttpjackson/JacksonSupport.scala +++ b/pekko-http-jackson/src/main/scala/com/github/pjfanning/pekkohttpjackson/JacksonSupport.scala @@ -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) diff --git a/pekko-http-upickle/src/test/scala/com/github/pjfanning/pekkohttpupickle/UpickleCustomizationSupportSpec.scala b/pekko-http-upickle/src/test/scala/com/github/pjfanning/pekkohttpupickle/UpickleCustomizationSupportSpec.scala index f2228e7..f253697 100644 --- a/pekko-http-upickle/src/test/scala/com/github/pjfanning/pekkohttpupickle/UpickleCustomizationSupportSpec.scala +++ b/pekko-http-upickle/src/test/scala/com/github/pjfanning/pekkohttpupickle/UpickleCustomizationSupportSpec.scala @@ -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() = { diff --git a/pekko-http-zio-json/src/main/scala/com/github/pjfanning/pekkohttpziojson/ZioJsonSupport.scala b/pekko-http-zio-json/src/main/scala/com/github/pjfanning/pekkohttpziojson/ZioJsonSupport.scala index 3c61523..ab7d682 100644 --- a/pekko-http-zio-json/src/main/scala/com/github/pjfanning/pekkohttpziojson/ZioJsonSupport.scala +++ b/pekko-http-zio-json/src/main/scala/com/github/pjfanning/pekkohttpziojson/ZioJsonSupport.scala @@ -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