Caller

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

Functions

accept

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

initialize

fun initialize(onCompletion: CompletionHandler)

perform

open suspend override fun perform(payload: SerializedPayload, stream: Flow<SerializedPayload>): SerializedPayload

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

protocol

val protocol: AscensionRPCProtocol

reference

val reference: RPCReference