Struct StreamingLoadQueue 

pub struct StreamingLoadQueue {
    pub pending: Vec<LoadRequest>,
    pub in_flight: Vec<LoadRequest>,
    pub max_concurrent: usize,
    pub total_bytes_loaded: u64,
    pub total_loads: u64,
    pub bandwidth_samples: VecDeque<f32>,
}

Fields

pending: Vec<LoadRequest>

in_flight: Vec<LoadRequest>

max_concurrent: usize

total_bytes_loaded: u64

total_loads: u64

bandwidth_samples: VecDeque<f32>

Implementations

impl StreamingLoadQueue

pub fn new(max_concurrent: usize) -> Self

pub fn enqueue(&mut self, request: LoadRequest)

pub fn dequeue_next(&mut self) -> Option<LoadRequest>

pub fn complete_load(&mut self, level_id: u64, bytes_loaded: u64, time_ms: f32)

pub fn cancel_load(&mut self, level_id: u64)

pub fn estimated_bandwidth_mb_s(&self) -> f32

pub fn estimated_remaining_time_ms(&self) -> f32

pub fn is_loading(&self, level_id: u64) -> bool

pub fn is_pending(&self, level_id: u64) -> bool

pub fn queue_depth(&self) -> usize

Trait Implementations

impl Debug for StreamingLoadQueue

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

Formats the value using the given formatter.