pub struct TransportSynchronizer { /* private fields */ }Implementations§
Source§impl TransportSynchronizer
impl TransportSynchronizer
pub fn new() -> Self
pub async fn fail(self, error: Error)
pub async fn get_sender( &self, key: &[u8], ) -> Option<UnboundedSender<IoResult<Packet>>>
Sourcepub async fn set_sender(
&self,
key: Vec<u8>,
sender: UnboundedSender<IoResult<Packet>>,
) -> Option<UnboundedSender<IoResult<Packet>>>
pub async fn set_sender( &self, key: Vec<u8>, sender: UnboundedSender<IoResult<Packet>>, ) -> Option<UnboundedSender<IoResult<Packet>>>
Sets the sender of a given key, returns the previous key if it was set
pub async fn remove_sender( &self, key: &[u8], ) -> Option<UnboundedSender<IoResult<Packet>>>
Trait Implementations§
Source§impl Clone for TransportSynchronizer
impl Clone for TransportSynchronizer
Source§fn clone(&self) -> TransportSynchronizer
fn clone(&self) -> TransportSynchronizer
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for TransportSynchronizer
impl !RefUnwindSafe for TransportSynchronizer
impl Send for TransportSynchronizer
impl Sync for TransportSynchronizer
impl Unpin for TransportSynchronizer
impl !UnwindSafe for TransportSynchronizer
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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