Struct AsyncMpscSender 

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

Implementations

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

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

Attempts to enqueue without blocking.

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

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

pub async fn send_batch<I>(&mut self, iter: I) -> Result<(), PushError<T>>

where I: IntoIterator<Item = T>,

pub fn close(&mut self) -> bool

Trait Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> Clone for AsyncMpscSender<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 AsyncMpscSender<T, P, NUM_SEGS_P2>

fn drop(&mut self)

Executes the destructor for this type.

impl<T, const P: usize, const NUM_SEGS_P2: usize> Sink<T> for AsyncMpscSender<T, P, NUM_SEGS_P2>

type Error = PushError<T>

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), PushError<T>>>

Attempts to prepare the Sink to receive a value.

fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), PushError<T>>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), PushError<T>>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), PushError<T>>>

Flush any remaining output and close this sink, if necessary.