fn flush_to_all(&mut self) {
        trace!("w{}: flush@{:?} to ALL - count: {}", self.worker_index, self.curr_cap, self.buffer.len());
        for writer in self.writers.iter_mut() {
            writer.push(Event::Messages(self.curr_cap.clone(), self.buffer.clone()));
        }
        self.buffer.drain(..);

        self.fuel = self.max_fuel;
        self.tick_sys = true;
    }
/// Flushes the buffer repeatedly, until all writers have received its content.
Flushes the buffer repeatedly, until all writers have received its content.
Flushes the buffer repeatedly until all writers have received its content .
fn flush_to_all(&mut self) {
        trace!("w{}: flush@{:?} to ALL - count: {}", self.worker_index, self.curr_cap, self.buffer.len());
        for writer in self.writers.iter_mut() {
            writer.push(Event::Messages(self.curr_cap.clone(), self.buffer.clone()));
        }
        self.buffer.drain(..);
        self.fuel = self.max_fuel;
        self.tick_sys = true;
    }
fn flush_to_all ( & mut self ) { trace ! ( " " self worker_index self curr_cap self buffer len ( ) ) ; for writer in self . writers . iter_mut ( ) { writer . push ( Event :: Messages ( self . curr_cap . clone ( ) , self . buffer . clone ( ) ) ) ; } self . buffer . drain ( .. ) ; self . fuel = self . max_fuel ; self . tick_sys = true ; }
Flushes the buffer repeatedly, until all writers have received its content.
Flushes the buffer repeatedly until all writers have received its content .
&mut self
&mut self