KtorRpcClient

abstract class KtorRpcClient : KrpcClient(source)

RpcClient implementation for Ktor, containing webSocketSession object, that is used to maintain connection.

Client is cold, meaning the connection will be established on the first request. webSocketSession will be completed when the connection is established.

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
abstract val webSocketSession: Deferred<WebSocketSession>

Cold WebSocketSession object. Instantiated when the connection is established on the first request.

Functions

Link copied to clipboard
suspend fun awaitCompletion()
Link copied to clipboard
suspend override fun <T> call(call: RpcCall): T
Link copied to clipboard
override fun <T> callServerStreaming(call: RpcCall): Flow<T>
Link copied to clipboard
fun close(message: String?)
Link copied to clipboard
protected abstract fun initializeConfig(): KrpcConfig.Client
Link copied to clipboard
protected abstract suspend fun initializeTransport(): KrpcTransport