Struct StreamFixtureSource 

pub struct StreamFixtureSource<'fixture> { /* private fields */ }

Borrowed ordered chunks for one deterministic finite source.

Implementations

impl<'fixture> StreamFixtureSource<'fixture>

pub const fn new( chunks: &'fixture [&'fixture [u8]], ) -> Result<Self, StreamFixtureError>

Creates one bounded source. Empty borrowed slices represent explicit empty chunks rather than end-of-stream.

pub const fn with_replayability( chunks: &'fixture [&'fixture [u8]], replayability: StreamReplayability<'fixture>, ) -> Result<Self, StreamFixtureError>

Creates a bounded source with an explicit replay capability.

pub const fn with_fault_at_observation( self, observation: usize, ) -> Result<Self, StreamFixtureError>

Injects a source failure at one one-based read observation.

pub const fn observations(&self) -> usize

Returns source observations including the final end marker.

Trait Implementations

impl AsyncStreamSource for StreamFixtureSource<'_>

type Error = StreamFixtureError

Source-specific payload-free failure.

fn replayability(&self) -> StreamReplayability<'_>

Returns explicit body replayability and exact source version.

async fn read_chunk<'operation>( &'operation mut self, output: &'operation mut [u8], ) -> Result<StreamRead, Self::Error>

Produces at most one chunk in a Send future.

impl BlockingStreamSource for StreamFixtureSource<'_>

type Error = StreamFixtureError

Source-specific payload-free failure.

fn replayability(&self) -> StreamReplayability<'_>

Returns explicit body replayability and exact source version.

fn read_chunk(&mut self, output: &mut [u8]) -> Result<StreamRead, Self::Error>

Produces at most one chunk and never retains output.