Struct Sender 

pub struct Sender<T> { /* private fields */ }

Sender half of a channel

Implementations

impl<T> Sender<T>

pub async fn send(&self, value: T) -> Result<(), SendError<T>>

Send a value through the channel

Examples found in repository

examples/channel_demo.rs (line 17)

fn main() {
    let rt = Runtime::new();

    rt.block_on(async move {
        let (tx, rx) = channel::bounded::<String>(10);

        // Spawn producer task
        rt.spawn({
            let tx = tx.clone();
            async move {
                for i in 0..5 {
                    let msg = format!("Message {}", i);
                    println!("Sending: {}", msg);
                    tx.send(msg).await.unwrap();
                    avx_async::sleep(Duration::from_millis(500)).await;
                }
            }
        });

        // Spawn another producer
        rt.spawn({
            async move {
                for i in 0..5 {
                    let msg = format!("Urgent {}", i);
                    println!("Sending: {}", msg);
                    tx.send(msg).await.unwrap();
                    avx_async::sleep(Duration::from_millis(300)).await;
                }
            }
        });

        // Receive messages
        let mut count = 0;
        while let Some(msg) = rx.recv().await {
            println!("Received: {}", msg);
            count += 1;
            if count >= 10 {
                break;
            }
        }

        println!("All messages received!");
    });
}

Trait Implementations

impl<T> Clone for Sender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Drop for Sender<T>

fn drop(&mut self)

Executes the destructor for this type.