Struct ProductReaderState 

pub struct ProductReaderState {
    pub buffer: Vec<u8>,
    pub done: bool,
    pub last_error: Option<Error>,
    pub max_buffer_overflowed: bool,
    pub loop_ptr: *mut PosixLoop,
    pub event_loop: EventLoopCtx,
}

Thin parent state shared by all product residual BufferedReader variants.

Callbacks update only these fields (disjoint from any embedded BufferedReader the domain type may hold later).

Fields

buffer: Vec<u8>

Accumulated chunks when HAS_ON_READ_CHUNK is true.

done: bool

Set by on_reader_done / on_reader_error / max-buffer overflow.

last_error: Option<Error>

Last error from on_reader_error (moved in).

max_buffer_overflowed: bool

Subprocess max-buffer budget tripped.

loop_ptr: *mut PosixLoop

Native loop backref (null until wired by the domain owner).

event_loop: EventLoopCtx

By-value event-loop handle (EventLoopCtx::default() = Mini + null).

Implementations

impl ProductReaderState

pub fn new() -> ProductReaderState

pub fn with_event_loop( self, loop_ptr: *mut PosixLoop, event_loop: EventLoopCtx, ) -> ProductReaderState

Wire a real Mini/Js event loop before attaching a live BufferedReader.

pub fn on_read_chunk(&mut self, chunk: &[u8], _has_more: ReadState) -> bool

pub fn on_reader_done(&mut self)

pub fn on_reader_error(&mut self, err: Error)

pub fn on_max_buffer_overflow(&mut self, _maxbuf: NonNull<MaxBuf>)

Trait Implementations

impl Default for ProductReaderState

fn default() -> ProductReaderState

Returns the “default value” for a type.