Struct netidx::publisher::Val

pub struct Val(_);

This represents a published value. Internally it is wrapped in an Arc, so cloning it is free. When all references to a given published value have been dropped it will be unpublished. However you must call flush before references to it will be removed from the resolver server.

Implementations

impl Val

pub fn downgrade(&self) -> ValWeak

pub fn update(&self, v: Value)

Queue an update to the published value, it will not be sent out until you call flush on the publisher, however new subscribers will receive the last value passed to update when they subscribe regardless of flush. Multiple updates can be queued before flush is called, in which case on flush subscribers will receive all the queued values in order. If updates are queued on multiple different published values before flush is called, they will all be sent out as a batch and are guarenteed to arrive in the order update was called.

pub fn writes(&self, tx: Sender<Batch>)

Register tx to receive writes. You can register multiple channels, and you can register the same channel on multiple Val objects. If no channels are registered to receive writes they will be ignored.

pub fn id(&self) -> Id

Get the unique Id of this Val

pub fn path(&self) -> &Path

Get a reference to the Path of this published value.

Trait Implementations

impl Clone for Val

fn clone(&self) -> Val

Returns a copy of the value.

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

Performs copy-assignment from source.