Struct Pending 

pub struct Pending<'a, T> { /* private fields */ }

An encoded record the caller has not yet acknowledged writing.

Returned by Encoder::encode. Write the payload, then commit.

A frame that is never committed never reached the wire. With compression on that is unrecoverable within the group: the window is ahead of what the consumer holds, and a log has no keyframe to resynchronize on the way snapshot does. So the encoder refuses to encode anything further (Error::Desync) until the caller rolls a new group and calls Encoder::reset. Without compression each record stands alone, so a dropped one leaves a gap in the log but nothing undecodable, and encoding continues.

Implementations

impl<T> Pending<'_, T>

pub fn payload(&self) -> &Bytes

The frame payload to write.

pub fn commit(self)

Acknowledge that the record reached the wire, keeping the encoder’s window.

Only call this once the write has actually succeeded.

Trait Implementations

impl<T> Drop for Pending<'_, T>

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.