Struct TrackedReceiver 

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

Receiver half of a tracked_sync_channel; records a dequeue for every item it yields so the gauge depth tracks the real backlog.

Implementations

impl<T> TrackedReceiver<T>

pub fn recv(&self) -> Result<T, RecvError>

Blocking receive that decrements the gauge for the item it returns.

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError>

pub fn try_recv(&self) -> Result<T, TryRecvError>

Trait Implementations

impl<T: Debug> Debug for TrackedReceiver<T>

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

Formats the value using the given formatter.