Struct Timed 

pub struct Timed<P, T = Timestamp> {
    pub value: P,
    pub at: Option<T>,
}

A value to publish, and optionally when it was captured.

T is the clock the time is on: a raw Timestamp by default, or whatever a higher layer maps onto one (moq-mux takes a std::time::Instant). Converts from a bare payload (bytes, or a &V to serialize), so a producer taking one still accepts the plain value, stamped when written.

Fields

value: P

The value to publish.

at: Option<T>

When the value was captured. None stamps it when written.

Implementations

impl<P, T> Timed<P, T>

pub fn at(self, at: T) -> Self

Set when the value was captured.

Trait Implementations

impl<P: Clone, T: Clone> Clone for Timed<P, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Copy, T: Copy> Copy for Timed<P, T>

impl<P: Debug, T: Debug> Debug for Timed<P, T>

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

Formats the value using the given formatter.

impl<'a, V, T> From<&'a V> for Timed<&'a V, T>

fn from(value: &'a V) -> Self

Converts to this type from the input type.

impl<B: Into<Bytes>, T> From<B> for Timed<Bytes, T>

fn from(value: B) -> Self

Converts to this type from the input type.