run parse asynchronously

pjfanning · May 17, 2024 · 3d58b32 · 3d58b32
1 parent de5641c
commit 3d58b32
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...http-argonaut/src/main/scala/com/github/pjfanning/pekkohttpargonaut/ArgonautSupport.scala b/...http-argonaut/src/main/scala/com/github/pjfanning/pekkohttpargonaut/ArgonautSupport.scala
@@ -146,7 +146,7 @@ trait ArgonautSupport {
     *   unmarshaller for any `A` value
     */
   implicit def fromByteStringUnmarshaller[A: DecodeJson]: Unmarshaller[ByteString, A] =
-    Unmarshaller(_ => bs => Future.successful(decode(parse(bs.utf8String))))
+    Unmarshaller(ec => bs => Future(decode(parse(bs.utf8String)))(ec))
 
   /**
     * HTTP entity => `Source[A, _]`

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
@@ -247,7 +247,7 @@ trait JacksonSupport {
         def unordered =
           Flow[ByteString].mapAsyncUnordered(support.parallelism)(asyncParse)
 
-        FastFuture.successful {
+        Future.successful {
           entity.dataBytes
             .via(support.framingDecoder)
             .via(if (support.unordered) unordered else ordered)