Struct Chunker

pub struct Chunker<C> {
    target: C,
    ready: VecDeque<C>,
}

Fields

target: C

Buffer into which we’ll consolidate.

Also the buffer where we’ll stage responses to extract and finish. When these calls return, the buffer is available for reuse.

ready: VecDeque<C>

Consolidated buffers ready to go.

Trait Implementations

impl<C: Container + Clone + 'static> ContainerBuilder for Chunker<C>

type Container = C

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<C: Default> Default for Chunker<C>

fn default() -> Chunker<C>

Returns the “default value” for a type.

impl<'a, D, T, R, C2> PushInto<&'a mut Column<(D, T, R)>> for Chunker<C2>

where D: Columnar, for<'b> D::Ref<'b>: Ord + Copy, T: Columnar, for<'b> T::Ref<'b>: Ord + Copy, R: Columnar + Semigroup + for<'b> Semigroup<R::Ref<'b>>, for<'b> R::Ref<'b>: Ord, C2: Container + for<'b> PushInto<&'b (D, T, R)>,

fn push_into(&mut self, container: &'a mut Column<(D, T, R)>)

Push item into self.