Struct PriorityConsumer 

pub struct PriorityConsumer { /* private fields */ }

Priority-aware consumer

Implementations

impl PriorityConsumer

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

pub fn with_batch_size(self, batch_size: usize) -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub async fn consume_batch(&self) -> Vec<PriorityMessage>

Consume messages in priority order

pub async fn consume_one(&self) -> Option<PriorityMessage>

Consume single message with timeout

pub async fn start_consuming<F, Fut>(&self, handler: F) -> Result<()>

where F: FnMut(PriorityMessage) -> Fut + Send, Fut: Future<Output = Result<()>> + Send,

Start consuming messages with a handler

Trait Implementations

impl Debug for PriorityConsumer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.