Struct AtomicGate 

pub struct AtomicGate(/* private fields */);

A shared atomic gate. Construct via AtomicGate::pair to get the gate (handed to the pipe) plus an AtomicGateController (kept by the caller to arm/disarm after the gate has been moved into the pipe).

Implementations

impl AtomicGate

pub fn pair(initial_armed: bool) -> (Self, AtomicGateController)

A gate and its controller, sharing one atomic. The gate moves into the Demand wrapper; the controller stays with the caller to signal demand.

Trait Implementations

impl DemandGate for AtomicGate

fn is_armed(&self) -> bool

true when at least one downstream consumer is active.

fn on_close(&self)

Called when the gate transitions armed→disarmed. Default no-op; a gate that fronts a crate::pipe::BoundedQueue overrides this to drain the queue and avoid losing items buffered during the coming dormancy.