Function tikv_util::mpsc::batch::unbounded [−][src]
pub fn unbounded<T>(notify_size: usize) -> (Sender<T>, Receiver<T>)
Creates a unbounded 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.