Struct BlockingMpscSender 

pub struct BlockingMpscSender<T, const P: usize, const NUM_SEGS_P2: usize> { /* private fields */ }

Blocking MPSC sender.

Multiple blocking senders can be created and used concurrently. They share the same waker infrastructure as async senders, allowing perfect interoperability.

Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> BlockingMpscSender<T, P, NUM_SEGS_P2>

pub fn try_send(&mut self, value: T) -> Result<(), PushError<T>>

pub fn send(&mut self, value: T) -> Result<(), PushError<T>>

Blocking send that parks the thread until space is available.

pub fn send_slice( &mut self, values: Vec<T>, ) -> Result<Vec<T>, PushError<Vec<T>>>

Sends multiple items from a slice, blocking until all are sent.

pub fn close(&mut self) -> bool

Trait Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> Clone for BlockingMpscSender<T, P, NUM_SEGS_P2>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, const P: usize, const NUM_SEGS_P2: usize> Drop for BlockingMpscSender<T, P, NUM_SEGS_P2>

fn drop(&mut self)

Executes the destructor for this type.