apollo-runtime/com.apollographql.apollo3.network.ws/SubscriptionWsProtocolAdapter

SubscriptionWsProtocolAdapter

open class SubscriptionWsProtocolAdapter(webSocketConnection: WebSocketConnection, listener: WsProtocol.Listener) : WsProtocol

Constructors

SubscriptionWsProtocolAdapter

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

Functions

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.

handleServerMessage

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

Handles a server message and notifies listener appropriately

open suspend fun run()

Read the WebSocket

open override fun <D : Operation.Data> startOperation(request: ApolloRequest<D>)

Starts the given operation

open override fun <D : Operation.Data> stopOperation(request: ApolloRequest<D>)

Stops the given operation