Function tikv_util::mpsc::batch::bounded [−][src]
pub fn bounded<T>(cap: usize, notify_size: usize) -> (Sender<T>, Receiver<T>)
Creates a bounded channel with a given notify_size
, which means if there are more pending
messages in the channel than notify_size
, the Sender
will auto notify the Receiver
.
Panics
if notify_size
equals to 0.