Struct SubGuard 

pub struct SubGuard { /* private fields */ }

Binding-layer RAII subscription handle (S2b / D225 / D234). The core-level RAII Subscription was retired (a parameterless Drop can’t reach a relocating owned Core); this wrapper IS the sanctioned binding-layer replacement for substrate operators that manage an inner subscription’s lifetime by ownership (higher-order switch/exhaust/merge/concat_map inner subs). It holds a ProducerEmitter (an Arc<CoreMailbox> — Send + Sync, 'static, NOT the Core), so its Drop legitimately posts a deferred unsubscribe via em.defer (owner-side, in-wave, FIFO-ordered — D234). FIFO ordering gives the correct cancel-then-resubscribe semantics: a SubGuard dropped before a new subscribe is posted is drained (unsub) before the new subscribe. A Core-gone post is dropped unrun (subscription moot at teardown — no leak).

Implementations

impl SubGuard

pub fn new(node: NodeId, sub: SubscriptionId, em: ProducerEmitter) -> Self

Track sub (returned by CoreFull::try_subscribe on node) so dropping this guard unsubscribes it.

Trait Implementations

impl Drop for SubGuard

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.