fn flush_buffer(&mut self) {
        trace!("w{} flush@{:?} to {} - count: {}", self.worker_index, self.curr_cap, self.curr_writer, self.buffer.len());
        if self.buffer.len() > 0 {
            if let Some(writer) = self.writers.get_mut(self.curr_writer) {
                writer.push(Event::Messages(self.curr_cap.clone(), std::mem::replace(&mut self.buffer, Vec::new())));
            } else {
                panic!("couldn't get writer");
            }
        }

        self.fuel = self.max_fuel;
        self.tick_sys = true;
    }
/// Flushes the buffer. The buffer is written out at `curr_cap`.
Flushes the buffer. The buffer is written out at `curr_cap`.
Flushes the buffer . The buffer is written out at ` curr_cap ` .
fn flush_buffer(&mut self) {
        trace!("w{} flush@{:?} to {} - count: {}", self.worker_index, self.curr_cap, self.curr_writer, self.buffer.len());
        if self.buffer.len() > 0 {
            if let Some(writer) = self.writers.get_mut(self.curr_writer) {
                writer.push(Event::Messages(self.curr_cap.clone(), std::mem::replace(&mut self.buffer, Vec::new())));
            } else {
                panic!("couldn't get writer");
            }
        }
        self.fuel = self.max_fuel;
        self.tick_sys = true;
    }
fn flush_buffer ( & mut self ) { trace ! ( " " self worker_index self curr_cap self curr_writer self buffer len ( ) ) ; if self . buffer . len ( ) > 0 { if let Some ( writer ) = self . writers . get_mut ( self . curr_writer ) { writer . push ( Event :: Messages ( self . curr_cap . clone ( ) , std :: mem :: replace ( & mut self . buffer , Vec :: new ( ) ) ) ) ; } else { panic ! ( " " ) ; } } self . fuel = self . max_fuel ; self . tick_sys = true ; }
Flushes the buffer.
Flushes the buffer .
&mut self
&mut self