Struct StreamAttempt 

pub struct StreamAttempt<'outcome> { /* private fields */ }

SDK-owned accounting attempt over caller-owned outcome state.

Only one source chunk may be outstanding. Dropping an active attempt marks it cancelled and records whether a sink write was never attempted, needs transactional rollback, or may already be externally visible.

Implementations

impl<'outcome> StreamAttempt<'outcome>

pub fn new(policy: StreamPolicy, outcome: &'outcome mut StreamOutcome) -> Self

Starts one attempt and marks the supplied outcome slot active.

pub const fn progress(&self) -> StreamProgress

Returns current counters.

pub fn begin_source_observation(&mut self) -> Result<(), StreamProgressError>

Reserves one source observation before external source code is called.

The returned source result must be classified with Self::begin_chunk, Self::observe_wait, or Self::finish.

pub fn begin_chunk(&mut self, len: usize) -> Result<(), StreamProgressError>

Classifies a preflight source observation as one complete chunk.

The next chunk is rejected until Self::advance accepts every pending byte, which makes backpressure deterministic.

pub fn begin_sink_observation(&mut self) -> Result<(), StreamProgressError>

Reserves one sink observation and conservatively records a write attempt before external sink code is called.

pub fn advance(&mut self, accepted: usize) -> Result<(), StreamProgressError>

Classifies a preflight sink observation with actual accepted bytes.

pub fn observe_wait(&mut self) -> Result<(), StreamProgressError>

Classifies a preflight source observation that produced no chunk.

pub fn mark_failed(&mut self)

Marks an external source or sink error so drop records failure, not cancellation.

pub fn finish(&mut self) -> Result<StreamCompletion, StreamProgressError>

Classifies a preflight source observation as end and validates length.

pub fn commit_sink(&mut self) -> Result<(), StreamProgressError>

Records successful sink commitment after Self::finish validated end.

Trait Implementations

impl Drop for StreamAttempt<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.