Struct VecChunker

pub struct VecChunker<T> { /* private fields */ }

Chunk a stream of vectors into chains of vectors.

Trait Implementations

impl<K, V, T, R> ContainerBuilder for VecChunker<((K, V), T, R)>

where K: Ord + Clone + 'static, V: Ord + Clone + 'static, T: Ord + Clone + 'static, R: Semigroup + Clone + 'static,

type Container = Vec<((K, V), T, R)>

The container type we’re building.

fn extract(&mut self) -> Option<&mut Self::Container>

Extract assembled containers, potentially leaving unfinished data behind. Can be called repeatedly, for example while the caller can send data.

fn finish(&mut self) -> Option<&mut Self::Container>

Extract assembled containers and any unfinished data. Should be called repeatedly until it returns None.

fn partition<I>( container: &mut Self::Container, builders: &mut [Self], index: I, )

where Self: for<'a> PushInto<<Self::Container as Container>::Item<'a>>, I: for<'a> FnMut(&<Self::Container as Container>::Item<'a>) -> usize,

Partitions container among builders, using the function index to direct items.

impl<T> Default for VecChunker<T>

fn default() -> Self

Returns the “default value” for a type.

impl<'a, K, V, T, R> PushInto<&'a mut Vec<((K, V), T, R)>> for VecChunker<((K, V), T, R)>

where K: Ord + Clone, V: Ord + Clone, T: Ord + Clone, R: Semigroup + Clone,

fn push_into(&mut self, container: &'a mut Vec<((K, V), T, R)>)

Push item into self.