Struct BoundedSourceQueue 

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

Materialized handle of Source::queue_bounded: a synchronous, bounded, lock-free queue with no overflow strategy (a full buffer drops). Clone; the stream completes when the last handle is dropped.

Implementations

impl<T> BoundedSourceQueue<T>

pub fn offer(&self, elem: T) -> QueueOfferResult

Offer one element. Returns immediately (never blocks): QueueOfferResult::Enqueued on success, QueueOfferResult::Dropped if the buffer is full, or QueueOfferResult::QueueClosed after completion/failure.

pub fn complete(&self)

Complete the stream after buffered elements drain (idempotent; first terminal signal wins).

pub fn fail(&self, error: StreamError)

Fail the stream; buffered elements drain before the error surfaces downstream.

Trait Implementations

impl<T: Clone> Clone for BoundedSourceQueue<T>

fn clone(&self) -> BoundedSourceQueue<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Drop for BoundedSourceQueue<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.