Struct Push 

pub(crate) struct Push {
    pub(crate) release_at: Instant,
    pub(crate) entered_backpressure: bool,
}

What PendingQueue::push did.

Fields

release_at: Instant

Pending::expected_at — the queue’s estimate of when this unit reaches the wire, which is the value to report as Effect::Queued { release_at }. It accounts for everything already queued, so it may be later than the action asked for, and for a unit behind a Hold it is that hold’s max_hold ceiling: an upper bound, since a gate may open at any time before it.

Not the unit’s own deadline. That is Pending::due_at, it is the only thing that gates the unit, and push never rewrites it.

entered_backpressure: bool

true exactly once per stream: on the push after which PendingQueue::accepts_more first turns false. Emit Impairment { EgressQueueFull { stream_id } } on it, and only on it — a queue that drains and fills again does not report twice.

Trait Implementations

impl Clone for Push

fn clone(&self) -> Push

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for Push

impl Debug for Push

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

Formats the value using the given formatter.

impl Eq for Push

impl PartialEq for Push

fn eq(&self, other: &Push) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Push