Struct MediaPriorityQueue

pub struct MediaPriorityQueue { /* private fields */ }

Priority queue for media chunks Uses your existing Queue internally but adds priority ordering

Implementations

impl MediaPriorityQueue

pub fn new(capacity: usize, priority_buffer_size: usize) -> Self

pub async fn enqueue(&self, chunk: MediaChunk) -> Result<(), QueueError>

pub fn dequeue(&self) -> impl Stream<Item = MediaChunk> + Send + 'static

pub async fn try_enqueue(&self, chunk: MediaChunk) -> Result<(), QueueError>

Try to enqueue without blocking - useful for live streaming

pub async fn close(&self)

pub async fn len(&self) -> usize