Struct QueueReadiness 

pub struct QueueReadiness<T>(/* private fields */);

A readiness signal backed by a ConcurrentQueue<T>.

The task considers itself ready when the queue is non-empty — i.e., one or more messages are waiting to be consumed.

This is the preferred signal for any TaskIterator that waits on a producer→consumer queue (file events, build results, SSE reload signals). The executor parks the task entirely and only wakes it when a message arrives. Zero CPU spinning.

Example

let queue = Arc::new(ConcurrentQueue::unbounded());
let readiness = QueueReadiness::new(queue.clone());

// In TaskIterator::next_status():
if let Ok(msg) = queue.pop() {
    return Some(TaskStatus::Ready(msg));
}
Some(TaskStatus::Depends(Arc::new(readiness)))

Implementations

impl<T> QueueReadiness<T>

pub fn new(queue: Arc<ConcurrentQueue<T>>) -> Self

Create a QueueReadiness that watches the given queue for messages.

pub fn queue(&self) -> Arc<ConcurrentQueue<T>>

Get a clone of the underlying queue for external mutation (pushing messages).

Trait Implementations

impl<T> Clone for QueueReadiness<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> EventReadiness for QueueReadiness<T>

Available on non-crate feature multi only.

fn is_ready(&self, _dur: Option<Duration>) -> bool

Check if the task is ready to run.