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 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.