Struct CallQueue 

pub struct CallQueue { /* private fields */ }

Implementations

impl CallQueue

pub fn start<F>(host: Host, opts: QueueOptions, work: F) -> CallQueue

where F: Fn(&ConcludedCall) -> Attempt + Send + Sync + 'static,

Start opts.threads workers running work on each call pushed — and on calls saved by the last shutdown, first.

pub fn push(&self, call: ConcludedCall)

pub fn len(&self) -> usize

Calls queued or being worked on.

pub fn is_empty(&self) -> bool

pub fn shutdown(&mut self, grace: Duration)

Work what’s ready until grace is nearly up; save the rest (or fail it). Call it from crate::Plugin::shutdown; calls pushed after it are refused.