Struct PriorityReceiver 

pub struct PriorityReceiver<T> { /* private fields */ }

Priority receiver that processes messages by priority

Combines multiple receivers and delivers messages in priority order. Messages with higher priority are processed before lower priority ones.

Implementations

impl<T> PriorityReceiver<T>

where T: Send + 'static,

pub fn new() -> Self

Create a new priority receiver with default configuration

pub fn with_config(config: PriorityQueueConfig) -> Self

Create a new priority receiver with custom configuration

pub fn add_source(&mut self, receiver: Receiver<T>, priority: Priority)

Add a message source with the specified priority

Example

let mut prio_rx = PriorityReceiver::new();

let emergency = ctx.subscribe("/safety/emergency").await?;
prio_rx.add_source(emergency, Priority::Critical);

let telemetry = ctx.subscribe("/sensor/telemetry").await?;
prio_rx.add_source(telemetry, Priority::Low);

pub async fn recv(&mut self) -> Option<(T, Priority)>

Receive the next message in priority order

Returns None when all sources are closed. Returns Some((message, priority)) with the highest priority message available.

Starvation Prevention

If configured, this method will occasionally process lower-priority messages even when higher-priority messages are available, to prevent starvation.

pub fn stats(&self) -> PriorityQueueStats

Get statistics about the priority queue

Trait Implementations

impl<T> Default for PriorityReceiver<T>

where T: Send + 'static,

fn default() -> Self

Returns the “default value” for a type.