Struct GraphObserveAllReactive 

pub struct GraphObserveAllReactive { /* private fields */ }

Reactive variant of GraphObserveAll that auto-subscribes late-added named nodes via Graph namespace-change notifications.

Drop to unsubscribe everything.

Implementations

impl GraphObserveAllReactive

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

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

Subscribe a sink to all current AND future named nodes.

The sink receives (name, &[Message]) tuples, same as GraphObserveAll::subscribe. Returns the number of nodes subscribed at call time (future auto-subscriptions are not counted).

Panics

Panics if called more than once on the same handle. The v1 contract is “single-shot wiring”; rebuild the handle via Graph::observe_all_reactive to install another sink.

Trait Implementations

impl Drop for GraphObserveAllReactive

fn drop(&mut self)

Executes the destructor for this type.