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.

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.