SubscriptionWsProtocolAdapter

The websocket implementation has moved to 'com.apollographql.apollo.network.websocket'. See https://go.apollo.dev/ak-v5-websockets for more details.

Constructors

constructor(webSocketConnection: WebSocketConnection, listener: WsProtocol.Listener)

open fun close()

Closes the connection gracefully. It is expected that a future call to WsProtocol.Listener.networkError is made

open suspend override fun connectionInit()

Initializes the connection and suspends until the server acknowledges it.

open override fun handleServerMessage(messageMap: Map<String, Any?>)

Handles a server message and notifies listener appropriately

open suspend fun run()

Read the WebSocket

Starts the given operation

Stops the given operation