Struct StreamState 

pub struct StreamState<T> { /* private fields */ }

Guest-side driver for an arena-style cdylib stream (FIDIUS-T-0138). Wraps the producer Stream<T> and holds the current item value (not its bytes), so a BUFFER_TOO_SMALL retry re-serializes the same item rather than advancing the iterator (which would drop it) — and so the happy path serializes directly into the host buffer with no Vec allocation.

Implementations

impl<T> StreamState<T>

where T: Serialize,

pub fn new(stream: Stream<T>) -> StreamState<T>

Wrap a producer stream.

pub fn next_into(&mut self, buf: &mut [u8]) -> NextStatus

Pull the next item (if needed) and serialize it directly into buf — no intermediate allocation. On TooSmall the item value is retained and re-serialized on the next (larger-buffer) call, so nothing is lost.