DefaultRPCNode

class DefaultRPCNode(contract: DefaultRPCNode.Contract, transport: RPCTransport) : RPCNode

Types

Contract

class Contract(payloadSerializer: PayloadSerializer, protocol: RPCProtocol, extensions: Map<RPCNodeExtension.Identifier<*>, RPCNodeExtension>) : RPCNode.Contract

Factory

class Factory(handshakePerformer: RPCHandshakePerformer, payloadSerializerFactory: PayloadSerializer.Factory, extensionFactories: List<RPCNodeExtension.Factory<*>>, providedServiceRegistry: ServiceRegistry)

Functions

getExtension

open override fun <E : RPCNodeExtension> getExtension(identifier: RPCNodeExtension.Identifier<E>): E?

run

suspend fun run(onInitializationCompleted: suspend () -> Unit)

Properties

contract

open override val contract: DefaultRPCNode.Contract

isActive

val isActive: Boolean

transport

val transport: RPCTransport