Struct ChangeEventBus

pub struct ChangeEventBus { /* private fields */ }

Implementations

impl ChangeEventBus

pub fn new() -> Self

Examples found in repository

examples/watch.rs (line 22)

fn main() {
    let mut bus = ChangeEventBus::new();
    
    // Subscribe to a simple scalar
    let rx_a = bus.subscribe(Foo::fields().a());

    // Subscribe to a nested field
    let rx_c = bus.subscribe(Foo::fields().bar().c());

    // Pretend our file-watcher detected changes:
    bus.publish("a", "42".into());
    bus.publish("bar.c", "\"updated\"".into());

    println!("got a   = {}", rx_a.recv().unwrap());
    println!("got bar.c = {}", rx_c.recv().unwrap());
}

pub fn subscribe(&mut self, field: FieldName) -> Receiver<String>

Subscribe to a particular field path.

Examples found in repository

examples/watch.rs (line 25)

fn main() {
    let mut bus = ChangeEventBus::new();
    
    // Subscribe to a simple scalar
    let rx_a = bus.subscribe(Foo::fields().a());

    // Subscribe to a nested field
    let rx_c = bus.subscribe(Foo::fields().bar().c());

    // Pretend our file-watcher detected changes:
    bus.publish("a", "42".into());
    bus.publish("bar.c", "\"updated\"".into());

    println!("got a   = {}", rx_a.recv().unwrap());
    println!("got bar.c = {}", rx_c.recv().unwrap());
}

pub fn publish(&self, path: &str, new_value: String)

Push a change onto the bus (e.g. "a" or "b.c").

Examples found in repository

examples/watch.rs (line 31)

fn main() {
    let mut bus = ChangeEventBus::new();
    
    // Subscribe to a simple scalar
    let rx_a = bus.subscribe(Foo::fields().a());

    // Subscribe to a nested field
    let rx_c = bus.subscribe(Foo::fields().bar().c());

    // Pretend our file-watcher detected changes:
    bus.publish("a", "42".into());
    bus.publish("bar.c", "\"updated\"".into());

    println!("got a   = {}", rx_a.recv().unwrap());
    println!("got bar.c = {}", rx_c.recv().unwrap());
}

Trait Implementations

impl Clone for ChangeEventBus

fn clone(&self) -> ChangeEventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ChangeEventBus

fn default() -> ChangeEventBus

Returns the “default value” for a type.