Callee
class Callee<REQUEST, CLIENT_STREAM, RESPONSE>(serializer: PayloadSerializer, call: RunnableCallDescription.ColdUpstream<REQUEST, CLIENT_STREAM, RESPONSE>) : RPC.Upstream.Callee.Implementation
Content copied to clipboard
Functions
perform
Link copied to clipboard
open suspend override fun perform(payload: SerializedPayload, stream: Flow<SerializedPayload>): SerializedPayload
Content copied to clipboard
Properties
call
Link copied to clipboard
val call: RunnableCallDescription.ColdUpstream<REQUEST, CLIENT_STREAM, RESPONSE>
Content copied to clipboard
serializer
Link copied to clipboard