Struct mz_ore::channel::InstrumentedUnboundedSender

pub struct InstrumentedUnboundedSender<T, M> {
    tx: UnboundedSender<T>,
    metric: M,
}

Available on crate feature async only.

A wrapper around tokio’s UnboundedSender that increments a metric when a send occurs.

The metric is not dropped until this sender is dropped.

Fields

tx: UnboundedSender<T>

metric: M

Implementations

impl<T, M> InstrumentedUnboundedSender<T, M>

where M: InstrumentedChannelMetric,

pub fn send(&self, message: T) -> Result<(), SendError<T>>

The same as UnboundedSender::send.

Trait Implementations

impl<T: Clone, M: Clone> Clone for InstrumentedUnboundedSender<T, M>

fn clone(&self) -> InstrumentedUnboundedSender<T, M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug, M: Debug> Debug for InstrumentedUnboundedSender<T, M>

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

Formats the value using the given formatter.