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)));