Function glommio::channels::local_channel::new_bounded

pub fn new_bounded<T>(size: usize) -> (LocalSender<T>, LocalReceiver<T>)

Creates a new local_channel with capacity limited to the size argument

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_bounded(1);
    assert_eq!(sender.is_full(), false);
    sender.try_send(0);
    assert_eq!(sender.is_full(), true);
    receiver.next().await.unwrap();
    assert_eq!(sender.is_full(), false);
});