Function abi_stable::external_types::crossbeam_channel::unbounded

pub fn unbounded<T>() -> (RSender<T>, RReceiver<T>)

Creates a channel which can hold an unbounded amount elements in its internal queue.

Example

use abi_stable::external_types::crossbeam_channel as mpmc;

let (tx, rx) = mpmc::unbounded::<&'static str>();

let join_guard = std::thread::spawn(move || {
    assert_eq!(rx.recv().unwrap(), "foo");
    assert_eq!(rx.recv().unwrap(), "bar");
    assert_eq!(rx.recv().unwrap(), "baz");
    assert!(rx.try_recv().is_err());
});

tx.send("foo").unwrap();
tx.send("bar").unwrap();
tx.send("baz").unwrap();

join_guard.join().unwrap();