Struct DeferredEffects 

pub(crate) struct DeferredEffects {
    q: VecDeque<Option<Deferred>>,
}

The ProxyEvent::ActionApplied events owed at release, in queue order.

A sibling FIFO of PendingQueue rather than a field on Pending, because Pending is egress.rs’s type and reporting is not its concern — that module deliberately emits no events at all.

The three-call discipline

Exactly one entry is pushed by execute on every PendingQueue::push, so self.len() == pending.len() at every point the caller can observe. In session.rs:

• release arm — one Self::pop per PendingQueue::pop_next_due, and each Some goes to Reporter::applied_deferred;
• after a DrainOutcome::Complete — Self::take_all, and every Some in it goes to applied_deferred: the drain wrote them, in order, and they are owed;
• after any other DrainOutcome — Self::clear, and nothing is emitted. Whatever the fallback could not flush is reported once as ImpairmentKind::QueuedBytesAtTeardown instead. The missing second event is the point: a unit lost at teardown must not have reported a Replaced that never reached the wire.

Fields

q: VecDeque<Option<Deferred>>

Implementations

impl DeferredEffects

pub(crate) fn new() -> Self

An empty ledger. Allocates nothing until the first push.

pub(crate) fn len(&self) -> usize

How many entries are owed. Equal to PendingQueue::len().

Read only by the tests below, which assert exactly that equality — the three-call discipline is what the pipe loops use, and none of them needs a count. Kept rather than #[cfg(test)]d because the equality is the ledger’s whole invariant and a reader looking for it should find the accessor beside it.

pub(crate) fn is_empty(&self) -> bool

Whether anything is owed. Tests only — see Self::len.

pub(crate) fn pop(&mut self) -> Option<Deferred>

The entry for the unit that was just released.

pub(crate) fn take_all(&mut self) -> Vec<Deferred>

Every entry still owed, in order. For a drain that completed.

pub(crate) fn clear(&mut self)

Forget everything owed. For a drain that did not complete.

fn push(&mut self, entry: Option<Deferred>)

Record one entry against one PendingQueue::push.

Trait Implementations

impl Debug for DeferredEffects

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DeferredEffects

fn default() -> DeferredEffects

Returns the “default value” for a type.