Function multiqueue::broadcast_fut_queue [] [src]

pub fn broadcast_fut_queue<T: Clone>(capacity: u64)
                                     -> (BroadcastFutSender<T>, BroadcastFutReceiver<T>)

Futures variant of broadcast_queue - datastructures implement Sink + Stream at a minor (~30 ns) performance cost to BlockingWait