Struct NativeReader 

pub struct NativeReader { /* private fields */ }

Reads only until another framed event is available. Dropping next while awaiting another body chunk retains decoder state and the current chunk. A decoder/transport error poisons this reader and releases its transport; transport is never replayed. Large/empty ready input cooperatively yields so cancellation and host deadlines remain observable.

Implementations

impl NativeReader

pub fn new(body: HttpBody, framing: SourceFraming, limits: CodecLimits) -> Self

pub async fn next<T: DeserializeOwned + DeclaredFields>( &mut self, ) -> Result<Option<NativeFrame<T>>, CodecError>