Struct Replies 

pub struct Replies { /* private fields */ }

Implementations

impl Replies

pub fn new() -> Replies

pub fn next_id(&self) -> u64

Mint a fresh request id.

pub fn deliver(&self, id: u64, reply: Reply)

Deliver a reply (the control thread).

pub fn close(&self)

The channel closed (supervisor gone): wake everyone.

pub fn is_closed(&self) -> bool

pub fn wait( &self, id: u64, deadline: Instant, cancel: &AtomicBool, ) -> Option<Reply>

Block until the reply for id arrives, the deadline passes, the channel closes, or cancel is set. Cancel is not signalled through the condvar, so the wait is capped at 100 ms per iteration to keep polling it. Returns None for every non-delivery ending. An already-delivered reply is claimed before any of those checks run, so a reply that landed before the call wins even against an expired deadline.

Trait Implementations

impl Default for Replies

fn default() -> Replies

Returns the “default value” for a type.