Struct StreamingManager 

pub struct StreamingManager { /* private fields */ }

Priority queue of pending asset loads.

Requests are dequeued in descending priority order. Ties are broken by enqueue time (older requests first — FIFO within a priority tier).

Implementations

impl StreamingManager

pub fn new(batch_size: usize) -> Self

Create a new manager.

batch_size — how many requests drain() returns at once.

pub fn enqueue(&mut self, req: StreamRequest)

Enqueue a load request.

If a request for the same ID already exists at a lower priority it is upgraded in-place. Duplicate same-priority requests are ignored.

pub fn drain(&mut self) -> Vec<StreamRequest>

Drain up to batch_size requests from the queue, highest priority first.

The returned requests have been removed from the queue.

pub fn cancel(&mut self, id: u64) -> bool

Remove a pending request by ID (e.g. asset was evicted before loading).

pub fn pending(&self) -> usize

Number of requests currently queued.

pub fn total_processed(&self) -> u64

Total requests ever processed (drained).

pub fn is_idle(&self) -> bool

true if no requests are waiting.

Trait Implementations

impl Debug for StreamingManager

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

Formats the value using the given formatter.