Function futures_delay_queue::unbuffered_delay_queue

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

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

Example

use futures_delay_queue::unbuffered_delay_queue;
use std::time::Duration;

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

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