Struct ContainerChunker

pub struct ContainerChunker<Output> { /* private fields */ }

Chunk a stream of containers into chains of vectors.

Trait Implementations

impl<Output> ContainerBuilder for ContainerChunker<Output>

where Output: SizableContainer + ConsolidateLayout + Clone + 'static,

type Container = Output

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<Output> Default for ContainerChunker<Output>

where Output: Default,

fn default() -> Self

Returns the “default value” for a type.

impl<'a, Input, Output> PushInto<&'a mut Input> for ContainerChunker<Output>

where Input: Container, Output: SizableContainer + ConsolidateLayout + PushInto<Input::Item<'a>>,

fn push_into(&mut self, container: &'a mut Input)

Push item into self.