Struct netidx::subscriber::Val

pub struct Val(_);

A non durable subscription to a value. If all user held references to Val are dropped then it will be unsubscribed.

Implementations

impl Val

pub fn downgrade(&self) -> ValWeak

pub async fn last<'_>(&'_ self) -> Option<Value>

Get the last published value, or None if the subscription is dead. Will only return None if the subscription is dead, otherwise there WILL be a value.

pub fn updates(&self, begin_with_last: bool, tx: Sender<Batch>)

Register tx to receive updates to this Val. If begin_with_last is true, then an immediate update will be sent consisting of the last value received from the publisher.

You may register multiple different channels to receive updates from a Val, and you may register one channel to receive updates from multiple Vals.

pub fn write(&self, v: Value)

Write a value back to the publisher. This will start going out as soon as this method returns, and you can call flush on the subscriber to get pushback in case of a slow publisher.

The publisher will receive multiple writes in the order you call write.

pub fn id(&self) -> SubId

Get the unique id of this subscription.

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.

impl Debug for Val

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.