Skip to main content

drain_rx

Function drain_rx 

Source
fn drain_rx(
    rx: &mut Receiver<(usize, usize)>,
    pending: &mut IndexSet<(usize, usize)>,
    warmed: &HashSet<(usize, usize)>,
)
Expand description

Drains any available items from rx into pending, skipping already-warmed and already-pending shapes. Non-blocking: returns as soon as try_recv fails.