Struct AutoflushSessionCore 

pub struct AutoflushSessionCore<'a, T, C, P: Push<BundleCore<T, C>> + 'a>
where
    T: Eq + Clone + 'a + Timestamp,
    C: 'a + Container,
{ /* private fields */ }

A session which will flush itself when dropped.

Implementations

impl<'a, T, D, P: Push<BundleCore<T, Vec<D>>> + 'a> AutoflushSessionCore<'a, T, Vec<D>, P>

where T: Eq + Clone + 'a + Timestamp, D: 'a + Data,

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 Vec<D>)

Transmits a pre-packed batch of data.

Trait Implementations

impl<'a, T, C, P: Push<BundleCore<T, C>> + 'a> Drop for AutoflushSessionCore<'a, T, C, P>

where T: Eq + Clone + 'a + Timestamp, C: 'a + Container,

fn drop(&mut self)

Executes the destructor for this type.