Struct QueueReceiver

pub struct QueueReceiver<T: Hash + Eq> { /* private fields */ }

Implementations

impl<T: Hash + Eq + Clone> QueueReceiver<T>

pub fn new( queue: Queue<T>, config: QueueReceiveConfig, sleeper: Arc<dyn Sleeper>, ) -> Self

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub async fn recv(&mut self) -> (Vec<T>, usize)

pub fn try_recv(&mut self) -> (Vec<T>, usize)

pub async fn recv_with(&mut self, overrides: &[Override]) -> (Vec<T>, usize)

Waits until some are available, then returns as many as possible, up to max_chunk_size. usize is the number remaining in the queue.

pub fn try_recv_with(&mut self, overrides: &[Override]) -> (Vec<T>, usize)

If any are available, returns them immediately. Otherwise returns an empty vec. usize is the number remaining in the queue.