Struct GraphObserveAll 

pub struct GraphObserveAll { /* private fields */ }

All-nodes observe handle. Subscriptions are tied to the set of nodes named at subscribe() call time. D246: no RAII Drop — You MUST call Self::detach(core) (owner-invoked) — these Core subscriptions are opened via raw core.subscribe and are NOT OwnedCore-tracked, so dropping the handle without detach leaks them for the Core lifetime.

Implementations

impl GraphObserveAll

pub fn subscribe<F>(&mut self, core: &Core, sink: F) -> usize

where F: Fn(&str, &[Message]) + 'static,

Multi-cast subscribe against every named node at this moment. Returns the node count.

pub fn detach(&mut self, core: &Core)

Owner-invoked, synchronous detach of every fan-out sink (D246 rule 3 — no Drop, so no Blind #4 deadlock class).