ProtocolBasedRPCTransport
class ProtocolBasedRPCTransport(protocol: RPCProtocol, payloadSerializer: PayloadSerializer) : RPCTransport
Content copied to clipboard
Functions
biStream
Link copied to clipboard
open suspend override fun <REQUEST, CLIENT_STREAM, RESPONSE> biStream(serviceCall: ColdBistreamCallDescription<REQUEST, CLIENT_STREAM, RESPONSE>, request: REQUEST, clientStream: Flow<CLIENT_STREAM>): Flow<RESPONSE>
Content copied to clipboard
clientStream
Link copied to clipboard
open suspend override fun <REQUEST, CLIENT_STREAM, RESPONSE> clientStream(serviceCall: ColdUpstreamCallDescription<REQUEST, CLIENT_STREAM, RESPONSE>, request: REQUEST, clientStream: Flow<CLIENT_STREAM>): RESPONSE
Content copied to clipboard
serverStream
Link copied to clipboard
open suspend override fun <REQUEST, RESPONSE> serverStream(serviceCall: ColdDownstreamCallDescription<REQUEST, RESPONSE>, request: REQUEST): Flow<RESPONSE>
Content copied to clipboard
singleCall
Link copied to clipboard
open suspend override fun <REQUEST, RESPONSE> singleCall(serviceCall: SingleCallDescription<REQUEST, RESPONSE>, request: REQUEST): RESPONSE
Content copied to clipboard