Struct Stream 

pub struct Stream<'d, B: Build<'d>, O: Origin = Stored> { /* private fields */ }

Incremental builder and the exact accounting state of its input.

Implementations

impl<'d, B: Build<'d>> Stream<'d, B>

pub fn new(open: Track<Open>, build: B) -> Self

pub fn finished(done: Track<Finished>, build: B) -> Self

impl<'d, B: Build<'d>, O: Origin> Stream<'d, B, O>

pub fn start(open: Track<Open>, build: B, ledger: &Ledger<'_, O>) -> Self

pub fn ended(done: Track<Finished>, build: B, ledger: &Ledger<'_, O>) -> Self

pub const fn max_body(&self) -> usize

pub const fn retention(&self) -> Retention

pub fn discard<E: Evidence>( self, ledger: &mut Ledger<'_, O>, event: &mut E, ) -> Discard<O>

pub fn abandon<E: Evidence>(self, event: E)

pub fn into_release(self) -> Release<O>

pub fn try_discard<E>( self, ledger: &mut Ledger<'_, O>, event: E, _: Segments<'d>, bytes: usize, boundary: Boundary, ) -> Transfer<Self, Error>

where E: Evidence,

pub fn try_push<D, I, E, F>( self, ledger: &mut Ledger<'_, O>, event: E, input: Input<D>, boundary: Boundary, (rmax, cmax): (Limits, Limits), parts: F, ) -> Push<D, Self, <B as Push<'d>>::Error>

where B: Push<'d>, I: Parts<'d>, E: Evidence, F: FnOnce(D) -> I,

pub fn try_finish<E: Evidence>( self, ledger: &mut Ledger<'_, O>, event: E, ) -> Transfer<Self, Error>

pub fn try_exact<E: Evidence>( self, ledger: &mut Ledger<'_, O>, event: E, len: usize, ) -> Transfer<Self, Error>

Finishes with the carrier’s final logical total, including prior input.

pub fn try_drive<E: Evidence>( self, ledger: &mut Ledger<'_, O>, event: E, budget: NonZero<usize>, ) -> (Drive<'d, B, O>, E)

pub fn try_step<E: Evidence>( self, ledger: &mut Ledger<'_, O>, event: &mut E, budget: NonZero<usize>, ) -> Drive<'d, B, O>

Trait Implementations

impl<'d, B: Build<'d>, O: Origin> Bind for Stream<'d, B, O>

type Origin = O

type Bound<Q: Origin> = Stream<'d, B, Q>

unsafe fn bind<Q: Origin>(self, origin: Q) -> Self::Bound<Q>

Safety