Trait tikv_util::mpsc::batch::BatchCollector

pub trait BatchCollector<Collection, Elem> {
    fn collect(
        &mut self, 
        collection: &mut Collection, 
        elem: Elem
    ) -> Option<Elem>;
}

A Collector Used in BatchReceiver.

Required methods

fn collect(&mut self, collection: &mut Collection, elem: Elem) -> Option<Elem>

If elem is collected into collection successfully, return None. Otherwise return elem back, and collection should be spilled out.

Loading content...

Implementors

impl<E> BatchCollector<Vec<E, Global>, E> for VecCollector

fn collect(&mut self, v: &mut Vec<E>, e: E) -> Option<E>

Loading content...