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.

Example

use futures_delay_queue::delay_queue;
use std::time::Duration;

let (delay_queue, expired_items) = delay_queue(0);
delay_queue.insert(1, Duration::from_millis(10));

// approximately 10ms later
assert_eq!(expired_items.receive().await, Some(1));