Function unbounded

Source
pub fn unbounded<I, P>() -> (Sender<I, P>, Receiver<I, P>)
where P: Ord,
Expand description

Creates an unbounded channel.

The created channel can hold an unlimited number of messages.

ยงExamples

let (s, r) = async_priority_channel::unbounded();

assert_eq!(s.send("Foo", 0).await, Ok(()));
assert_eq!(s.send("Bar", 2).await, Ok(()));
assert_eq!(s.send("Baz", 1).await, Ok(()));
assert_eq!(r.recv().await, Ok(("Bar", 2)));