Struct sc_utils::mpsc::TracingUnboundedSender

pub struct TracingUnboundedSender<T> { /* private fields */ }

Wrapper Type around async_channel::Sender that increases the global measure when a message is added.

Implementations

impl<T> TracingUnboundedSender<T>

pub fn is_closed(&self) -> bool

Proxy function to async_channel::Sender.

pub fn close(&self) -> bool

Proxy function to async_channel::Sender.

pub fn unbounded_send(&self, msg: T) -> Result<(), TrySendError<T>>

Proxy function to async_channel::Sender::try_send.

pub fn len(&self) -> usize

The number of elements in the channel (proxy function to async_channel::Sender).

Trait Implementations

impl<T> Clone for TracingUnboundedSender<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for TracingUnboundedSender<T>

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

Formats the value using the given formatter.