fn process_ready(&self) -> Result<(), ()> {
        let mut events = 0;
        let mut iter = self.try_iter();

        loop {
            match iter.next() {
                Some(event) => {
                    debug!("Received event: {:#?}", event);
                    events += 1;
                }
                None => {
                    info!("Found {} events", events);
                    return Ok(());
                }
            }
        }
    }
/// Non-blocking, read all the events already received -- draining
/// the event queue.
Non-blocking, read all the events already received -- draining
the event queue.
Non - blocking read all the events already received -- draining the event queue .
fn process_ready(&self) -> Result<(), ()> {
        let mut events = 0;
        let mut iter = self.try_iter();
        loop {
            match iter.next() {
                Some(event) => {
                    debug!("Received event: {:#?}", event);
                    events += 1;
                }
                None => {
                    info!("Found {} events", events);
                    return Ok(());
                }
            }
        }
    }
fn process_ready ( & self ) -> Result < ( ) , ( ) > { let mut events = 0 ; let mut iter = self . try_iter ( ) ; loop { match iter . next ( ) { Some ( event ) => { debug ! ( " " event ) ; events += 1 ; } None => { info ! ( " " events ) ; return Ok ( ( ) ) ; } } } }
Non-blocking, read all the events already received -- draining
the event queue.
Non - blocking read all the events already received -- draining the event queue .
&self
&self