Struct State 

pub struct State<'d, D, B>
where
    D: Session<'d>,
{ /* private fields */ }

One protocol-neutral session paired with its carrier-owned input buffer.

Implementations

impl<'d, D, B> State<'d, D, B>

where D: Session<'d>, B: Buf<'d>,

pub fn open(session: D, buffer: B) -> Self

pub fn finished(session: D, buffer: B) -> Self

pub fn into_buffer(self) -> B

Cancels the session and returns its queued carrier input.

pub const fn status(&self) -> Status

pub fn work(&self) -> Work

pub fn push( &mut self, input: B::Input, boundary: Boundary, ) -> Result<(), PushError<B::Input, B::Error>>

Appends one exact DATA owner to the carrier buffer without exposing the session machine between admission and callback consumption.

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

Records one peer FIN. Empty input can enter the machine immediately; queued bytes retain priority over the terminal callback.

pub fn transact<R, E>( &mut self, admit: impl for<'turn> FnOnce(Emission<'turn, 'd, D>) -> Admission<'turn, 'd, D, R, E>, ) -> Turn<Transaction<R, E>, B::Receipt>

Removes at most one carrier quantum and executes exactly one canonical session/admission transaction. The returned receipt proves which carrier quantum was removed during this transaction.