Struct StreamPatternSource 

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

Non-terminating stream source used to verify cancellation and hard bounds.

Implementations

impl<'fixture> StreamPatternSource<'fixture>

pub const fn new( pattern: StreamPattern<'fixture>, ) -> Result<Self, StreamFixtureError>

Creates a deterministic non-terminating source pattern.

pub const fn observations(&self) -> usize

Returns the number of source observations.

Trait Implementations

impl AsyncStreamSource for StreamPatternSource<'_>

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 StreamPatternSource<'_>

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.