Struct rt_graph::observable_value::ObservableValue

pub struct ObservableValue<T> where
    T: Clone,  { /* fields omitted */ }

A value that implements the Observer pattern.

Consumers can connect to receive callbacks when the value changes.

Implementations

impl<T> ObservableValue<T> where
    T: Clone, 

pub fn new(initial_value: T) -> ObservableValue<T>

Construct an ObservableValue.

pub fn get(&self) -> &T

Get the current value

pub fn set(&mut self, new_value: &T)

Set a new value and notify all connected subscribers.

pub fn connect<F>(&mut self, callback: F) -> SubscriptionId where
    F: Fn(&T) + 'static, 

Connect a new subscriber that will receive callbacks when the value is set.

Returns a SubscriptionId to disconnect the subscription when no longer required.

pub fn disconnect(&mut self, sub_id: SubscriptionId)

Disconnect an existing subscription.

pub fn split(self) -> (ReadHalf<T>, WriteHalf<T>)

Divide this instance into a read half (can listen for updates, but cannot write new values) and a write half (can write new values).