ColdBistreamCallDescription

data class ColdBistreamCallDescription<REQUEST, CLIENT_STREAM, SERVER_STREAM>(identifier: ServiceCallIdentifier, outgoingSerializer: KSerializer<REQUEST>, clientStreamSerializer: KSerializer<CLIENT_STREAM>, serverStreamSerializer: KSerializer<SERVER_STREAM>, errorSerializer: RPCErrorSerializer) : DownstreamCallDescription<REQUEST> , UpstreamCallDescription<REQUEST, CLIENT_STREAM>
Content copied to clipboard

Functions

calling
Link copied to clipboard
common
fun calling(method: suspend (REQUEST, Flow<CLIENT_STREAM>) -> Flow<SERVER_STREAM>): RunnableCallDescription<REQUEST>
Content copied to clipboard

Properties

clientStreamSerializer
Link copied to clipboard
common
open override val clientStreamSerializer: KSerializer<CLIENT_STREAM>
Content copied to clipboard
errorSerializer
Link copied to clipboard
common
open override val errorSerializer: RPCErrorSerializer
Content copied to clipboard
identifier
Link copied to clipboard
common
open override val identifier: ServiceCallIdentifier
Content copied to clipboard
outgoingSerializer
Link copied to clipboard
common
val outgoingSerializer: KSerializer<REQUEST>
Content copied to clipboard
payloadSerializer
Link copied to clipboard
common
open override val payloadSerializer: KSerializer<REQUEST>
Content copied to clipboard
serverStreamSerializer
Link copied to clipboard
common
val serverStreamSerializer: KSerializer<SERVER_STREAM>
Content copied to clipboard