Struct timely::dataflow::channels::pushers::buffer::AutoflushSession

pub struct AutoflushSession<'a, T: Timestamp, D, P: Push<(T, Content<D>)> + 'a> where
    T: Eq + Clone + 'a,
    D: 'a,  { /* fields omitted */ }

A session which will flush itself when dropped.

Methods

impl<'a, T: Timestamp, D, P: Push<(T, Content<D>)> + 'a> AutoflushSession<'a, T, D, P> where
    T: Eq + Clone + 'a,
    D: 'a, 

pub fn give(&mut self, data: D)

Transmits a single record.

pub fn give_iterator<I: Iterator<Item = D>>(&mut self, iter: I)

Transmits records produced by an iterator.

pub fn give_content(&mut self, message: &mut Content<D>)

Transmits a pre-packed batch of data.

Trait Implementations

impl<'a, T: Timestamp, D, P: Push<(T, Content<D>)> + 'a> Drop for AutoflushSession<'a, T, D, P> where
    T: Eq + Clone + 'a,
    D: 'a, 

fn drop(&mut self)

Executes the destructor for this type.