pub struct SequencedBroadcast<T> { /* private fields */ }Implementations§
Source§impl<T: Send + Clone + 'static> SequencedBroadcast<T>
impl<T: Send + Clone + 'static> SequencedBroadcast<T>
pub fn new( next_seq: u64, settings: SequencedBroadcastSettings, ) -> (Self, SequencedSender<T>)
pub fn new2( receiver: SequencedReceiver<T>, settings: SequencedBroadcastSettings, ) -> Self
pub async fn add_client( &self, next_sequence: u64, allow_drop: bool, ) -> Result<SequencedReceiver<T>, NewClientError>
pub fn metrics_ref(&self) -> &SequencedBroadcastMetrics
pub fn metrics(&self) -> Arc<SequencedBroadcastMetrics>
pub fn worker_loops(&self) -> u64
pub fn shutdown(self) -> Receiver<()>
pub async fn shutdown_wait(self)
pub fn closed(self) -> Receiver<()>
Auto Trait Implementations§
impl<T> Freeze for SequencedBroadcast<T>
impl<T> !RefUnwindSafe for SequencedBroadcast<T>
impl<T> Send for SequencedBroadcast<T>where
T: Send,
impl<T> Sync for SequencedBroadcast<T>where
T: Send,
impl<T> Unpin for SequencedBroadcast<T>
impl<T> !UnwindSafe for SequencedBroadcast<T>
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