GraphQLWebSocketClient

class GraphQLWebSocketClient(httpClient: HttpClient, url: String, connectionTimeout: Long)

GraphQL WebSocket client implementing graphql-transport-ws protocol.

Protocol: graphql-transport-ws Spec: https://github.com/enisdenjo/graphql-ws/blob/master/PROTOCOL.md

Connection Lifecycle:

Thread Safety: All methods are thread-safe and can be called from any coroutine.

httpClient

Ktor HTTP client with WebSockets installed

url

WebSocket URL (wss://...)

connectionTimeout

Timeout for connection_ack (milliseconds)

Constructors

constructor(httpClient: HttpClient, url: String, connectionTimeout: Long)

suspend fun close()

Close connection gracefully.

suspend fun connect()

Connect to WebSocket server.

suspend fun ping()

Send ping message (keep-alive).

fun subscribe(query: String, variables: Map<String, Any>? = null, operationName: String? = null): Flow<JsonElement>

Subscribe to GraphQL operation.