Merge pull request #4352 from prisma/fix-subscription-termination

fix subscription termination
prisma · Apr 11, 2019 · 3db4f2f · 3db4f2f
2 parents e620b02 + b76b6ea
commit 3db4f2f
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...criptions/src/main/scala/com/prisma/subscriptions/protocol/SubscriptionSessionActor.scala b/...criptions/src/main/scala/com/prisma/subscriptions/protocol/SubscriptionSessionActor.scala
@@ -1,6 +1,6 @@
 package com.prisma.subscriptions.protocol
 
-import akka.actor.{Actor, ActorRef, Stash}
+import akka.actor.{Actor, ActorRef, PoisonPill, Stash}
 import com.prisma.akkautil.{LogUnhandled, LogUnhandledExceptions}
 import com.prisma.api.ApiMetrics
 import com.prisma.jwt.Auth
@@ -108,6 +108,9 @@ case class SubscriptionSessionActor(
     case GqlStop(id) =>
       subscriptionsManager ! EndSubscription(id, sessionId, projectId)
 
+    case GqlConnectionTerminate =>
+      context.parent ! PoisonPill
+
     case _: CreateSubscriptionSucceeded =>
     // NOOP