fn process_queue(&mut self) {
        for entry in self.inner.process.take() {
            debug!("process_queue: {:?} match start", (entry.when_internal(), entry.load_state()));
            match (entry.when_internal(), entry.load_state()) {
                (None, None) => {
                    // Nothing to do
                }
                (Some(_), None) => {
                    // Remove the entry
                    self.clear_entry(&entry);
                }
                (None, Some(when)) => {
                    // Queue the entry
                    debug!("process_queue add_entry start");
                    self.add_entry(entry, when);
                    debug!("process_queue add_entry end");
                }
                (Some(_), Some(next)) => {
                    self.clear_entry(&entry);
                    self.add_entry(entry, next);
                }
            }
            debug!("process_queue match done");
        }
    }
/// Processes the entry queue
///
/// This handles adding and canceling timeouts.
Processes the entry queue
This handles adding and canceling timeouts.
Processes the entry queue This handles adding and canceling timeouts .
fn process_queue(&mut self) {
        for entry in self.inner.process.take() {
            debug!("process_queue: {:?} match start", (entry.when_internal(), entry.load_state()));
            match (entry.when_internal(), entry.load_state()) {
                (None, None) => {
                    // Nothing to do
                }
                (Some(_), None) => {
                    // Remove the entry
                    self.clear_entry(&entry);
                }
                (None, Some(when)) => {
                    // Queue the entry
                    debug!("process_queue add_entry start");
                    self.add_entry(entry, when);
                    debug!("process_queue add_entry end");
                }
                (Some(_), Some(next)) => {
                    self.clear_entry(&entry);
                    self.add_entry(entry, next);
                }
            }
            debug!("process_queue match done");
        }
    }
fn process_queue ( & mut self ) { for entry in self . inner . process . take ( ) { debug ! ( " " ( entry when_internal ( ) entry load_state ( ) ) ) ; match ( entry . when_internal ( ) , entry . load_state ( ) ) { ( None , None ) => { // Nothing to do } ( Some ( _ ) , None ) => { // Remove the entry self . clear_entry ( & entry ) ; } ( None , Some ( when ) ) => { // Queue the entry debug ! ( " " ) ; self . add_entry ( entry , when ) ; debug ! ( " " ) ; } ( Some ( _ ) , Some ( next ) ) => { self . clear_entry ( & entry ) ; self . add_entry ( entry , next ) ; } } debug ! ( " " ) ; } }
Processes the entry queue
This handles adding and canceling timeouts.
Processes the entry queue This handles adding and canceling timeouts .
&mut self