Struct StreamFixtureSink 

pub struct StreamFixtureSink<'storage> { /* private fields */ }

Caller-buffered deterministic sink with configurable short writes.

Implementations

impl<'storage> StreamFixtureSink<'storage>

pub fn new( output: &'storage mut [u8], max_write_bytes: usize, ) -> Result<Self, StreamFixtureError>

Creates a sink and clears all caller storage before first use.

pub const fn with_fault_at_write( self, write: usize, ) -> Result<Self, StreamFixtureError>

Injects a sink failure at one one-based write attempt.

pub fn bytes(&self) -> &[u8]

Returns initialized sink bytes.

pub const fn writes(&self) -> usize

Returns deterministic sink write count.

pub const fn is_committed(&self) -> bool

Reports whether the successful stream was committed.

pub const fn aborted_with(&self) -> Option<StreamPartialState>

Returns the last incomplete-state abort classification.

Trait Implementations

impl AsyncStreamSink for StreamFixtureSink<'_>

type Error = StreamFixtureError

Sink-specific payload-free failure.

async fn write_chunk<'operation>( &'operation mut self, input: &'operation [u8], ) -> Result<usize, Self::Error>

Accepts some or all bytes in a Send future.

async fn commit(&mut self) -> Result<(), Self::Error>

Commits a successfully validated stream in a Send future.

fn abort(&mut self, partial: StreamPartialState)

Synchronously aborts on error or future cancellation.

impl BlockingStreamSink for StreamFixtureSink<'_>

type Error = StreamFixtureError

Sink-specific payload-free failure.

fn write_chunk(&mut self, input: &[u8]) -> Result<usize, Self::Error>

Accepts some or all bytes. A zero result is a bounded no-progress event.

fn commit(&mut self) -> Result<(), Self::Error>

Commits a successfully validated stream.

fn abort(&mut self, partial: StreamPartialState)

Aborts an incomplete stream according to its recorded partial state.