Struct BoxedStream 

pub struct BoxedStream(/* private fields */);

A component-state stream of any concrete type, behind one dynamic dispatch.

Constructing one is the explicit, greppable point where a registered stream stops being monomorphized. Erasure does not change the stream’s namespace, definition identity, checkpoint selection, or restart semantics: representation is never restart-relevant (ADR-0008).

Implementations

impl BoxedStream

pub fn new<S: ItemStream + 'static>(stream: S) -> Self

Erases a concrete stream.

Trait Implementations

impl ItemStream for BoxedStream

fn open<'a>( &'a self, context: StreamOpenContext<'a>, ) -> impl Future<Output = Result<StreamOpenOutcome, StreamOpenError>> + Send + 'a

Restores last committed state, or begins initial execution.

fn update<'a>( &'a self, context: StreamUpdateContext<'a>, ) -> impl Future<Output = Result<ComponentStateEnvelope, StreamUpdateError>> + Send + 'a

Produces the candidate component-state envelope for the chunk about to commit.

fn close<'a>( &'a self, context: StreamCloseContext<'a>, ) -> impl Future<Output = Result<StreamCloseOutcome, StreamCloseError>> + Send + 'a

Runs once for every stream that opened successfully in this step attempt.