ColdUpstream

class ColdUpstream<REQUEST, CLIENT_STREAM, RESPONSE>(identifier: ServiceCallIdentifier, requestSerializer: KSerializer<REQUEST>, clientStreamSerializer: KSerializer<CLIENT_STREAM>, responseSerializer: KSerializer<RESPONSE>, errorSerializer: RPCErrorSerializer, perform: suspend (REQUEST, Flow<CLIENT_STREAM>) -> RESPONSE) : RunnableCallDescription<REQUEST>

Functions

interceptedWith

common

fun interceptedWith(interceptor: RPCIncomingInterceptor): RunnableCallDescription.ColdUpstream<REQUEST, CLIENT_STREAM, RESPONSE>

Properties

clientStreamSerializer

common

val clientStreamSerializer: KSerializer<CLIENT_STREAM>

errorSerializer

common

val errorSerializer: RPCErrorSerializer

identifier

common

val identifier: ServiceCallIdentifier

payloadSerializer

common

val payloadSerializer: KSerializer<REQUEST>

perform

common

val perform: suspend (REQUEST, Flow<CLIENT_STREAM>) -> RESPONSE

requestSerializer

common

val requestSerializer: KSerializer<REQUEST>

responseSerializer

common

val responseSerializer: KSerializer<RESPONSE>