Caller
class Caller<REQUEST, CLIENT_STREAM, SERVER_STREAM>(serializer: PayloadSerializer, rpc: RPC.Bistream.Caller, call: ColdBistreamCallDescription<REQUEST, CLIENT_STREAM, SERVER_STREAM>)
Content copied to clipboard
Functions
run
Link copied to clipboard
suspend fun run(payload: REQUEST, stream: Flow<CLIENT_STREAM>): Flow<SERVER_STREAM>
Content copied to clipboard