Struct MaxState 

pub struct MaxState<T>(pub T);

Tuple Fields

0: T

Trait Implementations

impl<T: Clone> Clone for MaxState<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Copy> Copy for MaxState<T>

impl<T: Debug> Debug for MaxState<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Mergeable for MaxState<i64>

fn merge(&mut self, other: Self)

Combine other into self, leaving self as the merged result and consuming other.

impl SpillCodec for MaxState<i64>

fn encode<W: Write>(&self, w: &mut W) -> Result<usize, SpillError>

Encode self into the writer. Returns the number of bytes written so the caller can track per-batch size.

fn decode<R: Read>(r: &mut R) -> Result<Option<Self>, SpillError>

Decode a fresh value from the reader. Reads exactly one element; returns Ok(None) on a clean end-of-file so drain loops can terminate naturally.

fn decode_with_budget<R: Read>( r: &mut R, _budget: &mut SpillDecodeBudget, ) -> Result<Option<Self>, SpillError>

Implementations must admit heap allocations before reserving them. The drain path refuses legacy codecs without a bounded implementation.