Callee
class Callee<REQUEST, CLIENT_STREAM, SERVER_STREAM>(serializer: PayloadSerializer, call: RunnableCallDescription.ColdBistream<REQUEST, CLIENT_STREAM, SERVER_STREAM>) : RPC.Bistream.Callee.Implementation
Content copied to clipboard
Functions
perform
Link copied to clipboard
open suspend override fun perform(payload: SerializedPayload, stream: Flow<SerializedPayload>): RPC.StreamOrError
Content copied to clipboard