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.