ColdDownstreamCallDescription

data class ColdDownstreamCallDescription<REQUEST, SERVER_STREAM>(identifier: ServiceCallIdentifier, outgoingSerializer: KSerializer<REQUEST>, serverStreamSerializer: KSerializer<SERVER_STREAM>, errorSerializer: RPCErrorSerializer) : DownstreamCallDescription<REQUEST>

Functions

calling

common

fun calling(method: suspend (REQUEST) -> Flow<SERVER_STREAM>): RunnableCallDescription<REQUEST>

Properties

errorSerializer

common

open override val errorSerializer: RPCErrorSerializer

identifier

common

open override val identifier: ServiceCallIdentifier

outgoingSerializer

common

val outgoingSerializer: KSerializer<REQUEST>

payloadSerializer

common

open override val payloadSerializer: KSerializer<REQUEST>

serverStreamSerializer

common

val serverStreamSerializer: KSerializer<SERVER_STREAM>