Struct Reducer 

pub struct Reducer {
    pub source: Vec<u64>,
    pub audit: AuditSink<AdditiveChain>,
}

Additive ReductionStream assembled from the AuditSink owner.

Fields

source: Vec<u64>

Immutable reduction source.

audit: AuditSink<AdditiveChain>

Owner of the consumed prefix, position, and result.

Implementations

impl Reducer

pub fn new(items: Vec<u64>) -> Reducer

Empty AuditSink over the immutable source.

pub fn position(&self) -> usize

Number of source elements already consumed.

pub fn result(&self) -> u64

Current additive result, projected from AuditSink’s carry.

pub fn remaining_len(&self) -> usize

Number of source elements not yet consumed.

pub fn done(&self) -> bool

Whether the complete source prefix has been reduced.

pub fn process(&mut self)

Consume the next source value through AuditSink’s Record action.