Struct AsyncUnboundedSpscProducer 

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

Asynchronous producer for unbounded SPSC queue.

This type provides async send operations for an unbounded queue that automatically expands by creating new segments as needed. Never blocks on full queue since the queue grows dynamically.

Implementations

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

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

Fast-path send without suspension.

For unbounded queues, this always succeeds unless the channel is closed.

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

Asynchronously sends a single item.

For unbounded queues, this typically completes immediately unless the channel is closed. The async interface is provided for API consistency.

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

Sends an entire Vec, moving items out using bulk operations.

On return, the Vec will be empty if all items were sent, or contain only the items that were not sent (if the channel closed).

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

where I: IntoIterator<Item = T>,

Sends every item from the iterator.

pub fn close(&mut self)

Closes the queue and wakes any waiters.

pub fn node_count(&self) -> usize

Returns the number of nodes in the unbounded queue.

pub fn total_capacity(&self) -> usize

Returns the total capacity across all nodes.

Trait Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> Sink<T> for AsyncUnboundedSpscProducer<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.