Skip to content
This repository was archived by the owner on Sep 2, 2022. It is now read-only.

Commit 3db4f2f

Browse files
authored
Merge pull request #4352 from prisma/fix-subscription-termination
fix subscription termination
2 parents e620b02 + b76b6ea commit 3db4f2f

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

server/servers/subscriptions/src/main/scala/com/prisma/subscriptions/protocol/SubscriptionSessionActor.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.prisma.subscriptions.protocol
22

3-
import akka.actor.{Actor, ActorRef, Stash}
3+
import akka.actor.{Actor, ActorRef, PoisonPill, Stash}
44
import com.prisma.akkautil.{LogUnhandled, LogUnhandledExceptions}
55
import com.prisma.api.ApiMetrics
66
import com.prisma.jwt.Auth
@@ -108,6 +108,9 @@ case class SubscriptionSessionActor(
108108
case GqlStop(id) =>
109109
subscriptionsManager ! EndSubscription(id, sessionId, projectId)
110110

111+
case GqlConnectionTerminate =>
112+
context.parent ! PoisonPill
113+
111114
case _: CreateSubscriptionSucceeded =>
112115
// NOOP
113116

0 commit comments

Comments
 (0)