Skip to content

Commit e52ee8e

Browse files
authored
fix issue 2092
Issue: #2092
1 parent 7b9676c commit e52ee8e

File tree

1 file changed

+5
-0
lines changed
  • servers/graphql-kotlin-server/src/main/kotlin/com/expediagroup/graphql/server/execution/subscription

1 file changed

+5
-0
lines changed

servers/graphql-kotlin-server/src/main/kotlin/com/expediagroup/graphql/server/execution/subscription/GraphQLWebSocketServer.kt

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ import graphql.GraphQLContext
3636
import kotlinx.coroutines.CoroutineScope
3737
import kotlinx.coroutines.FlowPreview
3838
import kotlinx.coroutines.Job
39+
import kotlinx.coroutines.job
3940
import kotlinx.coroutines.SupervisorJob
4041
import kotlinx.coroutines.coroutineScope
4142
import kotlinx.coroutines.delay
@@ -82,6 +83,10 @@ abstract class GraphQLWebSocketServer<Session, Message>(
8283
closeSession(session, GraphQLSubscriptionStatus.CONNECTION_INIT_TIMEOUT)
8384
}
8485
}
86+
87+
(session as? CoroutineScope)?.coroutineContext?.job?.invokeOnCompletion {
88+
subscriptions.values.forEach(Job::cancel)
89+
}
8590

8691
requestParser.parseRequestFlow(session)
8792
.map { objectMapper.readValue<GraphQLSubscriptionMessage>(it) }

0 commit comments

Comments
 (0)