Struct Sender 

pub struct Sender<T> {
    inner: Sender<T>,
}

🔬This is a nightly-only experimental API. (oneshot_channel #143674)

The sending half of a oneshot channel.

Examples

#![feature(oneshot_channel)]
use std::sync::oneshot;
use std::thread;

let (sender, receiver) = oneshot::channel();

thread::spawn(move || {
    sender.send("Hello from thread!").unwrap();
});

assert_eq!(receiver.recv().unwrap(), "Hello from thread!");

Sender cannot be sent between threads if it is sending non-Send types.

#![feature(oneshot_channel)]
use std::sync::oneshot;
use std::thread;
use std::ptr;

let (sender, receiver) = oneshot::channel();

struct NotSend(*mut ());
thread::spawn(move || {
    sender.send(NotSend(ptr::null_mut()));
});

let reply = receiver.try_recv().unwrap();

Fields

inner: Sender<T>

🔬This is a nightly-only experimental API. (oneshot_channel #143674)

The oneshot channel is simply a wrapper around a mpmc channel.

Implementations

impl<T> Sender<T>

pub fn send(self, t: T) -> Result<(), SendError<T>>

🔬This is a nightly-only experimental API. (oneshot_channel #143674)

Attempts to send a value through this channel. This can only fail if the corresponding Receiver<T> has been dropped.

This method is non-blocking (wait-free).

Examples

#![feature(oneshot_channel)]
use std::sync::oneshot;
use std::thread;

let (tx, rx) = oneshot::channel();

thread::spawn(move || {
    // Perform some computation.
    let result = 2 + 2;
    tx.send(result).unwrap();
});

assert_eq!(rx.recv().unwrap(), 4);

Trait Implementations

impl<T> Debug for Sender<T>

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

Formats the value using the given formatter.

impl<T> Sync for Sender<T>