Struct differential_dataflow::operators::join::EffortBuilder

pub struct EffortBuilder<CB>(pub Cell<usize>, pub CB);

A container builder that tracks the length of outputs to estimate the effort of join closures.

Tuple Fields

0: Cell<usize>

1: CB

Trait Implementations

impl<CB: ContainerBuilder> ContainerBuilder for EffortBuilder<CB>

type Container = <CB as ContainerBuilder>::Container

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<CB: Debug> Debug for EffortBuilder<CB>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<CB: Default> Default for EffortBuilder<CB>

fn default() -> EffortBuilder<CB>

Returns the “default value” for a type.

impl<CB: PushInto<D>, D> PushInto<D> for EffortBuilder<CB>

fn push_into(&mut self, item: D)

Push item into self.