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

CurrentRpcCallElement

class CurrentRpcCallElement(val method: RpcMethod<*, *, *>, val id: RpcCallId?) : AbstractCoroutineContextElement

Coroutine-context element describing the RPC call currently being handled by a ksrpc dispatcher. Installed at the single chokepoint where the user's handler body is invoked (RpcMethod.call) so that the handler can introspect its own call identity (for correlating progress notifications, streaming side-channels, etc.) via currentRpcCall.

Because the element is (re)installed at each handler invocation, nested outbound calls naturally see a fresh element installed at the destination's RpcMethod.call — no caller-side stripping is required.

Constructors

constructor(method: RpcMethod<*, *, *>, id: RpcCallId?)

Types

CurrentRpcCall

object CurrentRpcCall : CoroutineContext.Key<CurrentRpcCallElement>

Key for CurrentRpcCallElement in a CoroutineContext.

Properties

val id: RpcCallId?

Transport-specific identifier for this call, or null for calls with no id on the wire (e.g. a JSON-RPC notification) and for in-process handler invocations that bypass a transport.

key

open override val key: CoroutineContext.Key<*>

method

val method: RpcMethod<*, *, *>

The RpcMethod being handled. Handlers can read its RpcMethod.endpoint, RpcMethod.metadata, etc. Not nullable — the element is only installed when a concrete method is being dispatched.

Functions

fold

open override fun <R> fold(initial: R, operation: (R, CoroutineContext.Element) -> R): R

get

open operator override fun <E : CoroutineContext.Element> get(key: CoroutineContext.Key<E>): E?

minusKey

open override fun minusKey(key: CoroutineContext.Key<*>): CoroutineContext

plus

open operator fun plus(context: CoroutineContext): CoroutineContext

toString

open override fun toString(): String