ksrpc-core/com.monkopedia.ksrpc.channels/ChannelHost

ChannelHost

interface ChannelHost<T> : SerializedChannel<T> , SingleChannelHost<T> , KsrpcEnvironment.Element<T>

A SerializedChannel that can host sub-services.

This could be a bidirectional conduit like a Connection, or it could be a hosting only service such as http hosting.

Inheritors

Connection

Properties

context

open val context: CoroutineContext

env

abstract val env: KsrpcEnvironment<T>

supportedTier

open val supportedTier: ServiceTier

The maximum ServiceTier this host supports. Defaults to ServiceTier.BIDI (full capability). Implementations with limited transport capabilities should override this to a lower tier.

transportName

open val transportName: String

A human-readable name for this transport, used in error messages when a service exceeds the supportedTier.

Functions

call

abstract suspend fun call(channelId: ChannelId, endpoint: String, data: CallData<T>, callId: RpcCallId?): CallData<T>

abstract suspend fun close()

abstract suspend fun close(id: ChannelId)

onClose

abstract suspend fun onClose(onClose: suspend () -> Unit)

Add a callback to be invoked when SuspendCloseable.close is called.

registerDefault

abstract suspend fun registerDefault(service: SerializedService<T>)

registerDefault

inline suspend fun <T : RpcService, S> SingleChannelHost<S>.registerDefault(service: T)

suspend fun <T : RpcService, S> SingleChannelHost<S>.registerDefault(service: T, obj: RpcObject<T>)

registerHost

abstract suspend fun registerHost(service: SerializedService<T>): ChannelId

Add a serialized service that can receive calls on this channel with the returned ChannelId. The calls will be allowed until close is called.

registerHost

inline suspend fun <T : RpcService, S> ChannelHost<S>.registerHost(service: T): ChannelId

suspend fun <T : RpcService, S> ChannelHost<S>.registerHost(service: T, obj: RpcObject<T>): ChannelId

Register a service to be hosted, the ChannelId ollocated to this service is returned. Generally this should not be called directly, as it will happen automatically when services are returned from KsMethod tagged methods.