Struct AsyncLoadQueue 

pub struct AsyncLoadQueue {
    pub pending: BTreeMap<u64, AsyncLoadRequest>,
    pub in_flight: HashMap<u64, AsyncLoadRequest>,
    pub completed: VecDeque<(u64, bool)>,
    pub cancelled: HashSet<u64>,
    pub next_id: u64,
    pub max_in_flight: usize,
    pub max_pending: usize,
}

Fields

pending: BTreeMap<u64, AsyncLoadRequest>

in_flight: HashMap<u64, AsyncLoadRequest>

completed: VecDeque<(u64, bool)>

cancelled: HashSet<u64>

next_id: u64

max_in_flight: usize

max_pending: usize

Implementations

impl AsyncLoadQueue

pub fn new(max_in_flight: usize, max_pending: usize) -> Self

pub fn enqueue( &mut self, coord: ChunkCoord, lod: LodLevel, priority: f32, frame: u64, ) -> u64

pub fn cancel(&mut self, request_id: u64)

pub fn cancel_coord(&mut self, coord: &ChunkCoord)

pub fn dispatch_available(&mut self, frame: u64) -> Vec<AsyncLoadRequest>

pub fn complete_request(&mut self, request_id: u64, success: bool)

pub fn drain_completed(&mut self) -> Vec<(u64, bool)>

pub fn is_pending(&self, coord: &ChunkCoord) -> bool

pub fn is_in_flight(&self, coord: &ChunkCoord) -> bool

pub fn pending_count(&self) -> usize

pub fn in_flight_count(&self) -> usize

pub fn update_priority(&mut self, coord: &ChunkCoord, new_priority: f32)

pub fn stale_requests( &self, current_frame: u64, max_age_frames: u64, ) -> Vec<u64>

Trait Implementations

impl Clone for AsyncLoadQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AsyncLoadQueue

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

Formats the value using the given formatter.