fn run(&mut self) {
        debug!("Starting loop");
        loop {
            if ! self.next() {
                break
            }
        }
        debug!("Done with loop");
    }
/// Runs in a loop, expects that its publisher might block
Runs in a loop, expects that its publisher might block
Runs in a loop expects that its publisher might block
fn run(&mut self) {
        debug!("Starting loop");
        loop {
            if ! self.next() {
                break
            }
        }
        debug!("Done with loop");
    }
fn run ( & mut self ) { debug ! ( " " ) ; loop { if ! self . next ( ) { break } } debug ! ( " " ) ; }
Runs in a loop, expects that its publisher might block
Runs in a loop expects that its publisher might block
&mut self
&mut self