Struct TrackedSyncSender 

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

A std::sync::mpsc::SyncSender that feeds a QueueGauge as items flow through it, so a queue whose backing channel cannot report its own length still participates in the centralized tracker.

send keeps the underlying blocking-backpressure semantics; it just records the enqueue first so near-capacity warnings fire as the queue fills.

Implementations

impl<T> TrackedSyncSender<T>

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

Blocking send: record the enqueue, then hand off to the bounded channel (which parks the caller until a slot is free: clean backpressure).

pub fn try_send(&self, value: T) -> Result<(), TrySendError<T>>

Non-blocking send: record the enqueue only on success. Lets a caller with its own deadline poll instead of parking indefinitely on a full queue.

pub fn gauge(&self) -> &Arc<QueueGauge>

The gauge backing this sender.

Trait Implementations

impl<T> Clone for TrackedSyncSender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for TrackedSyncSender<T>

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

Formats the value using the given formatter.