Struct fluvio_socket::ExclusiveFlvSink [−][src]
pub struct ExclusiveFlvSink { /* fields omitted */ }
Expand description
Multi-thread aware Sink. Only allow sending request one a time.
Implementations
pub async fn send_request<R>(
&self,
req_msg: &RequestMessage<R>
) -> Result<(), SocketError> where
RequestMessage<R>: FlvEncoder + Default + Debug,
pub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version
) -> Result<(), SocketError> where
ResponseMessage<P>: FlvEncoder + Default + Debug,
pub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version
) -> Result<(), SocketError> where
ResponseMessage<P>: FlvEncoder + Default + Debug,
helper method to send back response
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for ExclusiveFlvSink
impl Send for ExclusiveFlvSink
impl Sync for ExclusiveFlvSink
impl Unpin for ExclusiveFlvSink
impl !UnwindSafe for ExclusiveFlvSink
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more