SessionNodeExtension

class SessionNodeExtension : ContextUpdateService, RPCNodeExtension

Types

Companion

object Companion

Factory

class Factory(sessionContextKeyRegistry: SessionContextKeyRegistry, payloadSerializerFactory: PayloadSerializer.Factory, plugins: List<SessionNodeExtension.Plugin>) : RPCNodeExtension.Factory<SessionNodeExtension>

Identifier

object Identifier : RPCNodeExtension.Identifier<SessionNodeExtension>

Plugin

interface Plugin

Functions

bind

open suspend override fun bind(transport: RPCTransport, contract: RPCNode.Contract)

Binds an extension to a transport.

clear

open suspend override fun clear()

enhanceParallelWorkContext

open suspend override fun enhanceParallelWorkContext(context: CoroutineContext): CoroutineContext

interceptIncomingBistreamCall

open suspend override fun <PAYLOAD, CLIENT_STREAM, SERVER_STREAM> interceptIncomingBistreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: RunnableCallDescription.ColdBistream<PAYLOAD, CLIENT_STREAM, SERVER_STREAM>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>

interceptIncomingDownstreamCall

open suspend override fun <PAYLOAD, SERVER_STREAM> interceptIncomingDownstreamCall(payload: PAYLOAD, call: RunnableCallDescription.ColdDownstream<PAYLOAD, SERVER_STREAM>, next: suspend (PAYLOAD) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>

interceptIncomingSingleCall

open suspend override fun <PAYLOAD, RESPONSE> interceptIncomingSingleCall(payload: PAYLOAD, call: RunnableCallDescription.Single<PAYLOAD, RESPONSE>, next: suspend (PAYLOAD) -> RESPONSE): RESPONSE

interceptIncomingUpstreamCall

open suspend override fun <PAYLOAD, CLIENT_STREAM, RESPONSE> interceptIncomingUpstreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: RunnableCallDescription.ColdUpstream<PAYLOAD, CLIENT_STREAM, RESPONSE>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> RESPONSE): RESPONSE

interceptOutgoingBistreamCall

open suspend override fun <PAYLOAD, CLIENT_STREAM, SERVER_STREAM> interceptOutgoingBistreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: ColdBistreamCallDescription<PAYLOAD, CLIENT_STREAM, SERVER_STREAM>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>

interceptOutgoingDownstreamCall

open suspend override fun <PAYLOAD, SERVER_STREAM> interceptOutgoingDownstreamCall(payload: PAYLOAD, call: ColdDownstreamCallDescription<PAYLOAD, SERVER_STREAM>, next: suspend (PAYLOAD) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>

interceptOutgoingSingleCall

open suspend override fun <PAYLOAD, RESPONSE> interceptOutgoingSingleCall(payload: PAYLOAD, call: SingleCallDescription<PAYLOAD, RESPONSE>, next: suspend (PAYLOAD) -> RESPONSE): RESPONSE

interceptOutgoingUpstreamCall

open suspend override fun <PAYLOAD, CLIENT_STREAM, RESPONSE> interceptOutgoingUpstreamCall(payload: PAYLOAD, stream: Flow<CLIENT_STREAM>, call: ColdUpstreamCallDescription<PAYLOAD, CLIENT_STREAM, RESPONSE>, next: suspend (PAYLOAD, Flow<CLIENT_STREAM>) -> RESPONSE): RESPONSE

update

open suspend override fun update(request: ContextUpdateRequest): ContextUpdateResult

whileConnected

open suspend override fun whileConnected()

Properties

providedServices

open override val providedServices: List<ServiceDescription>

session

val session: Session