Struct AsyncStreamSender 

pub struct AsyncStreamSender<T> { /* private fields */ }

Producer handle for a BoundedAsyncStream.

Cheap to clone (Arc under the hood). Drop the last AsyncStreamSender to close the stream; the consumer’s next() will yield None once the buffer is empty.

Implementations

impl<T> AsyncStreamSender<T>

pub fn push(&self, item: T)

Push an item; drops the oldest queued item if the buffer is at capacity. This is the lossy default.

pub fn push_or_block(&self, item: T) -> Result<(), T>

Push an item, blocking the current thread if the buffer is full until the consumer drains an item.

Returns Err(item) if the consumer side has been dropped — the item is returned to the caller so it isn’t leaked.

Errors

Returns Err(item) if the consumer has been dropped.

Panics

Panics if any mutex is poisoned by another thread panicking while holding it.

pub fn buffered_count(&self) -> usize

Returns the number of items currently buffered.

pub fn is_consumer_gone(&self) -> bool

Returns true if the consumer has been dropped.

Trait Implementations

impl<T> Clone for AsyncStreamSender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for AsyncStreamSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Drop for AsyncStreamSender<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.