Struct glommio::channels::local_channel::LocalSender

pub struct LocalSender<T> { /* fields omitted */ }

Send endpoint to the local_channel

Implementations

impl<T> LocalSender<T>

pub fn try_send(&self, item: T) -> Result<(), GlommioError<T>>

Sends data into this channel.

It returns a GlommioError::Closed encapsulating a BrokenPipe if the receiver is destroyed. It returns a GlommioError::WouldBlock encapsulating a WouldBlock if this is a bounded channel that has no more capacity

Examples

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

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, receiver) = local_channel::new_bounded(1);
    sender.try_send(0);
    sender.try_send(0).unwrap_err(); // no more capacity
    receiver.stream().next().await.unwrap(); // now we have capacity again
    drop(receiver); // but because the receiver is destroyed send will err
    sender.try_send(0).unwrap_err();
});

pub async fn send(&self, item: T) -> Result<(), GlommioError<T>>

Sends data into this channel when it is ready to receive it

For an unbounded channel this is just a more expensive version of try_send. Prefer to use try_send instead.

For a bounded channel this will push to the channel when the channel is ready to receive data.

Examples

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

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, receiver) = local_channel::new_bounded(1);
    sender.send(0).await.unwrap();
    drop(receiver);
});

pub fn is_full(&self) -> bool

Checks if there is room to send data in this channel

Examples

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

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, receiver) = local_channel::new_bounded(1);
    assert_eq!(sender.is_full(), false);
    sender.try_send(0);
    assert_eq!(sender.is_full(), true);
    drop(receiver);
});

pub fn len(&self) -> usize

Returns the number of items still queued in this channel

Examples

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

let ex = LocalExecutor::default();
ex.run(async move {
    let (sender, mut receiver) = local_channel::new_unbounded();
    sender.try_send(0);
    sender.try_send(0);
    assert_eq!(sender.len(), 2);
    receiver.stream().next().await.unwrap();
    assert_eq!(sender.len(), 1);
    drop(receiver);
});

Trait Implementations

impl<T: Debug> Debug for LocalSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Drop for LocalSender<T>

fn drop(&mut self)

Executes the destructor for this type.