Caller

class Caller<REQUEST, CLIENT_STREAM, RESPONSE>(serializer: PayloadSerializer, rpc: RPC.Upstream.Caller, call: ColdUpstreamCallDescription<REQUEST, CLIENT_STREAM, RESPONSE>)
Content copied to clipboard

Functions

run
Link copied to clipboard
suspend fun run(payload: REQUEST, stream: Flow<CLIENT_STREAM>): RESPONSE
Content copied to clipboard

Properties

call
Link copied to clipboard
val call: ColdUpstreamCallDescription<REQUEST, CLIENT_STREAM, RESPONSE>
Content copied to clipboard
rpc
Link copied to clipboard
val rpc: RPC.Upstream.Caller
Content copied to clipboard
serializer
Link copied to clipboard
val serializer: PayloadSerializer
Content copied to clipboard