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.