Struct Decoder 

pub struct Decoder<'d, T: Decode<C>, C: Copy = ()> { /* private fields */ }

Resumable decoder. Input, replay, field lookup, and owner release work are charged to the caller-provided budget. Its driver brand cannot be widened even when the scanner owns every input segment.

Error retirement charges input owners, field slots, and array elements. Fixed-schema scalar destruction and allocation metadata are constant work; an arbitrary user-provided materializer or destructor must uphold its own cooperative work contract. Dropping a decoder cancels it immediately.

Implementations

impl<'d, T: Decode> Decoder<'d, T>

pub fn try_stream() -> Result<Self, Create>

Creates a decoder whose input is still being received.

pub fn new(segments: Vec<Shared>) -> Result<Self, Error>

pub fn one(segment: Shared) -> Result<Self, Error>

pub fn from_scoped(segments: Vec<Shared<'d>>) -> Result<Self, Error>

Creates a decoder over owners which remain tied to their driver.

impl<'d, T: Decode<C>, C: Copy> Decoder<'d, T, C>

pub fn try_feed(context: C) -> Result<Self, Create>

Starts streaming directly into the final output representation.

pub fn push(self, segment: Shared<'d>) -> Transfer<Self, Push<'d>>

Transfers one retained transport owner into the decoder.

pub fn close(self) -> Self

Declares that no more input segments can arrive.

pub fn take_bytes(&mut self) -> usize

Returns original input bytes retired by scanning or scanner-error cleanup since the previous call. Materialization and cancellation retain the caller’s remaining transport credit until its terminal settlement.

pub fn take_chunks(&mut self) -> Count

Returns original transport owners retired by scanning or scanner-error cleanup. Projected copies are never counted as new transport owners.

pub fn release(&mut self, budget: &mut usize) -> Poll<()>

Cooperatively retires this decoder without materializing another value.

pub fn poll(&mut self, budget: NonZero<usize>) -> Progress<'d, T>

Performs bounded work while preserving whether the decoder needs scheduling or another transport segment.