Struct differential_dataflow::trace::abomonated_blanket_impls::AbomonatedMerger

pub struct AbomonatedMerger<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> + Abomonation> Merger<K, V, T, R, Abomonated<B, Vec<u8>>> for AbomonatedMerger<K, V, T, R, B>

Represents a merge in progress.

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

Perform some amount of work, decrementing fuel.

fn done(self) -> Abomonated<B, Vec<u8>>

Extracts merged results.