Struct differential_dataflow::trace::rc_blanket_impls::RcMerger

pub struct RcMerger<K, V, T, R, B: Batch<K, V, T, R>> { /* fields omitted */ }

Wrapper type for merging reference counted batches.

Trait Implementations

impl<K, V, T, R, B: Batch<K, V, T, R>> Merger<K, V, T, R, Rc<B>> for RcMerger<K, V, T, R, B>

Represents a merge in progress.

fn new(source1: &Rc<B>, source2: &Rc<B>) -> Self

Creates a new merger to merge the supplied batches.

fn work(     &mut self,     source1: &Rc<B>,     source2: &Rc<B>,     frontier: &Option<Vec<T>>,     fuel: &mut usize )

Perform some amount of work, decrementing fuel.

fn done(self) -> Rc<B>

Extracts merged results.