Struct DeltaStream

pub struct DeltaStream<T: Streamable> { /* private fields */ }

A stream impl that writes the difference between the last value and the current value to the provided MutBits writer. The previous value is initialized to 0.

Implementations

impl<T: Streamable> DeltaStream<T>

pub fn new(writer: Box<dyn Stream<T>>) -> Self

Create a new stream impl

Trait Implementations

impl<S: Streamable + ToSigned<Output = T>, T: Streamable + NumberSigned + Sub<Output = T>> Stream<S> for DeltaStream<T>

fn write_value(&mut self, value: S) -> Result<usize, Error>

Deltifies the value against the previous value and writes it out.

fn flush(&mut self) -> Result<(), Error>

fn written_stats(&self) -> String