Struct PendingQueue 

pub struct PendingQueue { /* private fields */ }

The queue itself. Inner.queue holds the registry; Inner.cv is the wake signal for parked vs_prompt_input calls. Wrapped in Arc<Mutex> so multiple daemon threads can share it.

Implementations

impl PendingQueue

pub fn new() -> Arc<Self>

pub fn enqueue_and_wait( &self, entry: PendingEntry, timeout: Duration, ) -> Option<String>

Enqueue a pending entry and block on the condvar until it is fulfilled, cancelled, or timeout elapses. Returns the value on fulfillment, None on cancellation or timeout.

pub fn list(&self) -> Vec<PendingEntry>

Snapshot of all pending entries (id + user-visible metadata).

pub fn fulfill(&self, id: &str, value: String) -> bool

Fulfill a pending entry with value. Wakes parked waiters.

pub fn cancel(&self, id: &str) -> bool

Cancel a pending entry.

pub fn peek(&self, id: &str) -> Option<PendingEntry>

Peek a pending entry (no removal).

Trait Implementations

impl Default for PendingQueue

fn default() -> PendingQueue

Returns the “default value” for a type.