Function glommio::channels::local_channel::new_unbounded

pub fn new_unbounded<T>() -> (LocalSender<T>, LocalReceiver<T>)

Creates a new local_channel with unbounded capacity

Examples

use glommio::{LocalExecutor, Local};
use glommio::channels::local_channel;
use futures_lite::StreamExt;

let ex = LocalExecutor::make_default();
ex.run(async move {
    let (sender, mut receiver) = local_channel::new_unbounded();
    let h = Local::local(async move {
        assert_eq!(receiver.next().await.unwrap(), 0);
    }).detach();
    sender.try_send(0);
    drop(sender);
    h.await;
});