fix: clients sometimes don't receive results

StarlaneStudios · Jun 25, 2023 · 5af1930 · 5af1930
1 parent fa21389
commit 5af1930
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/kotlin/org/starlane/graphqlwskt/client/ClientHandler.kt b/src/main/kotlin/org/starlane/graphqlwskt/client/ClientHandler.kt
@@ -102,8 +102,6 @@ internal class ClientHandler(
 	fun <T : Any> subscribe(request: OperationRequest, type: KClass<T>): Flow<T> {
 		val id = UUID.randomUUID().toString()
 
-		send(Subscribe(id, request))
-
 		return channelFlow {
 			subscriptions[id] = ActiveSubscription(
 				onNext = {
@@ -117,6 +115,7 @@ internal class ClientHandler(
 				}
 			)
 
+			send(Subscribe(id, request))
 			awaitClose()
 		}
 	}