ColdUpstreamCallDescription

data class ColdUpstreamCallDescription<REQUEST, CLIENT_STREAM, RESPONSE>(identifier: ServiceCallIdentifier, outgoingSerializer: KSerializer<REQUEST>, clientStreamSerializer: KSerializer<CLIENT_STREAM>, incomingSerializer: KSerializer<RESPONSE>, errorSerializer: RPCErrorSerializer) : UpstreamCallDescription<REQUEST, CLIENT_STREAM>

Functions

calling

common

fun calling(method: suspend (REQUEST, Flow<CLIENT_STREAM>) -> RESPONSE): RunnableCallDescription<REQUEST>

Properties

clientStreamSerializer

common

open override val clientStreamSerializer: KSerializer<CLIENT_STREAM>

errorSerializer

common

open override val errorSerializer: RPCErrorSerializer

identifier

common

open override val identifier: ServiceCallIdentifier

incomingSerializer

common

val incomingSerializer: KSerializer<RESPONSE>

outgoingSerializer

common

val outgoingSerializer: KSerializer<REQUEST>

payloadSerializer

common

open override val payloadSerializer: KSerializer<REQUEST>