Struct differential_dataflow::trace::implementations::chunker::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,

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.

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>> + PushInto<Input::ItemRef<'a>>,

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

Push item into self.