Searched defs:Prioritize (Results 1 – 1 of 1) sorted by relevance
26 pub(super) struct Prioritize { struct28 pending_send: store::Queue<stream::NextSend>,31 pending_capacity: store::Queue<stream::NextSendCapacity>,46 pending_open: store::Queue<stream::NextOpen>,71 pub(crate) struct Prioritized<B> { argument81 // ===== impl Prioritize ===== argument83 impl Prioritize { impl84 pub fn new(config: &Config) -> Prioritize { in new()