AscensionRPCProtocol

class AscensionRPCProtocol(connection: RPCConnection, frameSerializer: TransportFrameSerializer, implementationRegistry: RPCImplementationRegistry) : RPCProtocol

Types

Factory

class Factory : RPCProtocol.Factory

Functions

bistream

open override fun bistream(serviceCallIdentifier: ServiceCallIdentifier): RPC.Bistream.Caller

downstream

open override fun downstream(serviceCallIdentifier: ServiceCallIdentifier): RPC.Downstream.Caller

run

open suspend override fun run()

send

suspend fun send(frame: AscensionRPCFrame)

singleCall

open override fun singleCall(serviceCallIdentifier: ServiceCallIdentifier): RPC.SingleCall.Caller

upstream

open override fun upstream(serviceCallIdentifier: ServiceCallIdentifier): RPC.Upstream.Caller

Properties

isActive

open override var isActive: Boolean

version

open override val version: RPCProtocol.Version