pub fn flush(&mut self) {
        // @TODO get rid of the double buffering maybe?
        self.handle
            .session(self.cap.clone())
            .give_iterator(self.buffer.drain(..));

        if self.cap.time().less_than(&self.time) {
            self.cap = self.cap.delayed(&self.time);
        }
    }
/// Forces buffered data into the timely dataflow input, and
/// advances its time to match that of the session.
///
/// It is important to call `flush` before expecting timely
/// dataflow to report progress. Until this method is called, all
/// updates may still be in internal buffers and not exposed to
/// timely dataflow. Once the method is called, all buffers are
/// flushed and timely dataflow is advised that some logical times
/// are no longer possible.
Forces buffered data into the timely dataflow input, and
advances its time to match that of the session.

It is important to call `flush` before expecting timely
dataflow to report progress. Until this method is called, all
updates may still be in internal buffers and not exposed to
timely dataflow. Once the method is called, all buffers are
flushed and timely dataflow is advised that some logical times
are no longer possible.
Forces buffered data into the timely dataflow input and advances its time to match that of the session . It is important to call ` flush ` before expecting timely dataflow to report progress . Until this method is called all updates may still be in internal buffers and not exposed to timely dataflow . Once the method is called all buffers are flushed and timely dataflow is advised that some logical times are no longer possible .
pub fn flush(&mut self) {
        // @TODO get rid of the double buffering maybe?
        self.handle
            .session(self.cap.clone())
            .give_iterator(self.buffer.drain(..));
        if self.cap.time().less_than(&self.time) {
            self.cap = self.cap.delayed(&self.time);
        }
    }
pub fn flush ( & mut self ) { // @TODO get rid of the double buffering maybe? self . handle . session ( self . cap . clone ( ) ) . give_iterator ( self . buffer . drain ( .. ) ) ; if self . cap . time ( ) . less_than ( & self . time ) { self . cap = self . cap . delayed ( & self . time ) ; } }
Forces buffered data into the timely dataflow input, and
advances its time to match that of the session.
Forces buffered data into the timely dataflow input and advances its time to match that of the session .
&mut self
&mut self