Struct Channel 

struct Channel<T> {
    buffer: BinaryHeap<Reverse<DelayedData<T>>>,
    waker: Option<Waker>,
    cfg: MixerConfig,
}

Mixing and delaying channel using random delay function.

Mixing is performed by assigning random delays to the ingress timestamp of data, then storing the values inside a binary heap with reversed ordering (max heap). This effectively creates a min heap behavior, which is required to ensure that data is released in order of their delay expiration.

When data arrives:

1. A random delay is assigned
2. Data is stored in the heap with its release timestamp
3. The heap maintains ordering so items with earliest release time are at the top

This channel is unbounded by nature using the capacity in the configuration to solely pre-allocate the buffer.

The timer used by the receiver to wait for the next release deadline is not stored behind this mutex — it lives on the Receiver itself. Keeping it out of the shared state is what lets the receiver poll the timer without blocking senders.

Fields

buffer: BinaryHeap<Reverse<DelayedData<T>>>

Buffer holding the data with a timestamp ordering to ensure the min heap behavior.

waker: Option<Waker>

cfg: MixerConfig