Caller

class Caller(protocol: AscensionRPCProtocol, context: CoroutineContext, serviceCallIdentifier: ServiceCallIdentifier, reference: RPCReference) : PendingRPC.Caller<AscensionRPCFrame.ColdDownstream.Downstream, AscensionRPCFrame.ColdDownstream.Upstream> , RPC.Downstream.Caller

Functions

accept

suspend fun accept(frame: AscensionRPCFrame.ColdDownstream.Downstream)

initialize

fun initialize(onCompletion: CompletionHandler)

perform

open suspend override fun perform(payload: SerializedPayload): RPC.StreamOrError

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

protocol

val protocol: AscensionRPCProtocol

reference

val reference: RPCReference