Struct fluvio_socket::ExclusiveFlvSink
source · pub struct ExclusiveFlvSink { /* private fields */ }
Expand description
Multi-thread aware Sink. Only allow sending request one a time.
Implementations§
source§impl ExclusiveFlvSink
impl ExclusiveFlvSink
pub fn new(sink: FluvioSink) -> Self
source§impl ExclusiveFlvSink
impl ExclusiveFlvSink
pub async fn lock(&self) -> MutexGuard<'_, FluvioSink>
pub async fn send_request<R>( &self, req_msg: &RequestMessage<R> ) -> Result<(), SocketError>
sourcepub async fn send_response<P>(
&mut self,
resp_msg: &ResponseMessage<P>,
version: Version
) -> Result<(), SocketError>
pub async fn send_response<P>( &mut self, resp_msg: &ResponseMessage<P>, version: Version ) -> Result<(), SocketError>
helper method to send back response
pub fn id(&self) -> ConnectionFd
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§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more