ColdBistream

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

Functions

interceptedWith

common

fun interceptedWith(interceptor: RPCIncomingInterceptor): RunnableCallDescription.ColdBistream<REQUEST, CLIENT_STREAM, SERVER_STREAM>

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>) -> Flow<SERVER_STREAM>

requestSerializer

common

val requestSerializer: KSerializer<REQUEST>

responseSerializer

common

val responseSerializer: KSerializer<SERVER_STREAM>