Struct GraphObserveAll 

pub struct GraphObserveAll { /* private fields */ }

All-nodes observe handle. subscribe multiplexes across every named node in the graph (NOT recursive into mounts — observers wanting recursion compose with child.observe_all() per subgraph).

The sink receives (name, &[Message]) tuples; name is the local namespace name. Subscriptions stay tied to the set of nodes named at observe_all() call time — late-added nodes are NOT auto-subscribed in this slice (lifts with the reactive observe topology-change primitive in a later slice).

Implementations

impl GraphObserveAll

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

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

Multi-cast subscribe — registers sink against every named node at this exact moment. Each underlying subscription is kept alive in self; drop the handle to unsubscribe all.

Returns the number of nodes the sink was registered against.