Struct Gate 

pub struct Gate(CancellationToken);

A cheap, clonable release handle the engine awaits.

Level-triggered: releasing before anyone waits is observed by every later waiter, so there is no lost-wakeup race. All clones share one release, and the handle is eight bytes.

The engine never awaits a gate on its own — it always races the gate against session cancellation and EgressConfig::max_hold, so a hook that never releases cannot make a stream unkillable.

Deliberately a newtype rather than an exposed CancellationToken: handing the engine the session’s own cancel token would conflate teardown with object release.

Tuple Fields

0: CancellationToken

Implementations

impl Gate

pub fn new() -> Self

A new, unreleased gate.

pub fn release(&self)

Release every holder. Idempotent.

pub fn is_released(&self) -> bool

Whether Self::release has been called.

pub(crate) async fn wait(&self)

Resolve once the gate is released. Engine-internal: callers race it against session cancellation and EgressConfig::max_hold.

Trait Implementations

impl Clone for Gate

fn clone(&self) -> Gate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Gate

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

Formats the value using the given formatter.

impl Default for Gate

fn default() -> Gate

Returns the “default value” for a type.