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 Freeze for ExclusiveFlvSink
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)