Fix WebSocket implementation

ghostdogpr · Mar 16, 2020 · 37951b2 · 37951b2
1 parent 6e69abb
commit 37951b2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/akka-http/src/main/scala/caliban/AkkaHttpAdapter.scala b/akka-http/src/main/scala/caliban/AkkaHttpAdapter.scala
@@ -121,7 +121,7 @@ object AkkaHttpAdapter extends FailFastCirceSupport {
                                   case ObjectValue((fieldName, StreamValue(stream)) :: Nil) =>
                                     stream.foreach { item =>
                                       sendMessage(queue, id, ObjectValue(List(fieldName -> item)), result.errors)
-                                    }.fork.flatMap(fiber => subscriptions.update(_.updated(id, fiber)))
+                                    }.forkDaemon.flatMap(fiber => subscriptions.update(_.updated(id, fiber)))
                                   case other =>
                                     sendMessage(queue, id, other, result.errors) *> IO.fromFuture(_ =>
                                       queue.offer(TextMessage(s"""{"type":"complete","id":"$id"}"""))

diff --git a/http4s/src/main/scala/caliban/Http4sAdapter.scala b/http4s/src/main/scala/caliban/Http4sAdapter.scala
@@ -147,7 +147,7 @@ object Http4sAdapter {
                                 case ObjectValue((fieldName, StreamValue(stream)) :: Nil) =>
                                   stream.foreach { item =>
                                     sendMessage(sendQueue, id, ObjectValue(List(fieldName -> item)), result.errors)
-                                  }.fork.flatMap(fiber => subscriptions.update(_.updated(id, fiber)))
+                                  }.forkDaemon.flatMap(fiber => subscriptions.update(_.updated(id, fiber)))
                                 case other =>
                                   sendMessage(sendQueue, id, other, result.errors) *> sendQueue.enqueue1(
                                     WebSocketFrame.Text(s"""{"type":"complete","id":"$id"}""")