Function sc_consensus::import_queue::buffered_link::buffered_link
source · pub fn buffered_link<B: BlockT>(
queue_size_warning: usize,
) -> (BufferedLinkSender<B>, BufferedLinkReceiver<B>)
Expand description
Wraps around an unbounded channel from the futures
crate. The sender implements Link
and
can be used to buffer commands, and the receiver can be used to poll said commands and transfer
them to another link. queue_size_warning
sets the warning threshold of the channel queue size.