Struct Tuple 

pub struct Tuple<S: Watcher, T: Watcher> { /* private fields */ }

Implementations

impl<S: Watcher, T: Watcher> Tuple<S, T>

pub fn new(s: S, t: T) -> Self

Trait Implementations

impl<S: Clone + Watcher, T: Clone + Watcher> Clone for Tuple<S, T>

where S::Value: Clone, T::Value: Clone,

fn clone(&self) -> Tuple<S, T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + Watcher, T: Debug + Watcher> Debug for Tuple<S, T>

where S::Value: Debug, T::Value: Debug,

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

Formats the value using the given formatter.

impl<S: Watcher, T: Watcher> Watcher for Tuple<S, T>

type Value = (<S as Watcher>::Value, <T as Watcher>::Value)

The type of value that can change.

fn update(&mut self) -> bool

Updates the watcher to the latest value and returns whether it changed.

fn peek(&self) -> &Self::Value

Returns a reference to the value currently stored in the watcher.

fn is_connected(&self) -> bool

Whether this watcher is still connected to all of its underlying Watchables.

fn poll_updated( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), Disconnected>>

Polls for the next value, or returns Disconnected if one of the underlying Watchables has been dropped.

fn get(&mut self) -> Self::Value

Updates the watcher to the latest value and returns that value.

fn updated(&mut self) -> NextFut<'_, Self>

Returns a future completing with Ok(value) once a new value is set, or with Err(Disconnected) if the connected Watchable was dropped.

fn initialized<T, W>(&mut self) -> InitializedFut<'_, T, W, Self>

where W: Nullable<T> + Clone, Self: Watcher<Value = W>,

Returns a future completing once the value is set to Some value.

fn stream(self) -> Stream<Self>

where Self: Unpin,

Returns a stream which will yield the most recent values as items.

fn stream_updates_only(self) -> Stream<Self>

where Self: Unpin,

Returns a stream which will yield the most recent values as items, starting from the next unobserved future value.

fn map<T: Clone + Eq>( self, map: impl Fn(Self::Value) -> T + Send + Sync + 'static, ) -> Map<Self, T>

Maps this watcher with a function that transforms the observed values.

fn or<W: Watcher>(self, other: W) -> Tuple<Self, W>

Returns a watcher that updates every time this or the other watcher updates, and yields both watcher’s items together when that happens.