Function futures_delay_queue::delay_queue

pub fn delay_queue<T: 'static + Send>(
    cap: usize
) -> (DelayQueue<T>, Receiver<T>)

Creates a delay queue and a multi consumer channel for receiving expired items.

This delay queue has a buffer that can hold at most cap messages at a time.

Panics

If cap is zero, this function will panic.