PendingRPC

abstract class PendingRPC<INCOMING : AscensionRPCFrame, OUTGOING : AscensionRPCFrame>(protocol: AscensionRPCProtocol, context: CoroutineContext, reference: RPCReference, logger: Logger) : CoroutineScope

Types

Callee

abstract class Callee<INCOMING : AscensionRPCFrame, AscensionRPCFrame.Upstream, OUTGOING : AscensionRPCFrame, AscensionRPCFrame.Downstream>(protocol: AscensionRPCProtocol, context: CoroutineContext, reference: RPCReference, logger: Logger) : PendingRPC<INCOMING, OUTGOING>

Caller

abstract class Caller<INCOMING : AscensionRPCFrame, AscensionRPCFrame.Downstream, OUTGOING : AscensionRPCFrame, AscensionRPCFrame.Upstream>(protocol: AscensionRPCProtocol, context: CoroutineContext, reference: RPCReference, logger: Logger) : PendingRPC<INCOMING, OUTGOING>

Functions

accept

suspend fun accept(frame: INCOMING)

initialize

fun initialize(onCompletion: CompletionHandler)

Properties

coroutineContext

open override val coroutineContext: CoroutineContext

protocol

val protocol: AscensionRPCProtocol

reference

val reference: RPCReference

Inheritors

PendingRPC

PendingRPC