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 futures_lite::StreamExt;
use glommio::{channels::local_channel, LocalExecutor};

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, receiver) = local_channel::new_unbounded();
    let h = glommio::spawn_local(async move {
        assert_eq!(receiver.stream().next().await.unwrap(), 0);
    })
    .detach();
    sender.try_send(0);
    drop(sender);
    h.await;
});