ChainingIncomingInterceptor

sealed class ChainingIncomingInterceptor : RPCIncomingInterceptor
Content copied to clipboard

Types

Companion
Link copied to clipboard
common
object Companion
Content copied to clipboard
Middle
Link copied to clipboard
Tail
Link copied to clipboard
common

Functions

interceptIncomingBistreamCall
Link copied to clipboard
common
open suspend 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>
Content copied to clipboard
interceptIncomingDownstreamCall
Link copied to clipboard
common
open suspend fun <PAYLOAD, SERVER_STREAM> interceptIncomingDownstreamCall(payload: PAYLOAD, call: RunnableCallDescription.ColdDownstream<PAYLOAD, SERVER_STREAM>, next: suspend (PAYLOAD) -> Flow<SERVER_STREAM>): Flow<SERVER_STREAM>
Content copied to clipboard
interceptIncomingSingleCall
Link copied to clipboard
common
open suspend fun <PAYLOAD, RESPONSE> interceptIncomingSingleCall(payload: PAYLOAD, call: RunnableCallDescription.Single<PAYLOAD, RESPONSE>, next: suspend (PAYLOAD) -> RESPONSE): RESPONSE
Content copied to clipboard
interceptIncomingUpstreamCall
Link copied to clipboard
common
open suspend 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
Content copied to clipboard

Inheritors