[][src]Struct pipe_channel::Sender

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

The sending half of a channel.

Methods

impl<T> Sender<T>[src]

pub fn send(&mut self, t: T) -> Result<(), SendError<T>>[src]

Send data to the corresponding Receiver.

This may block if the underlying syscall blocks, namely if the pipe buffer is full.

Errors

If the corresponding Receiver is already dropped, this method will return Err(SendError(t)), transferring the ownership over t back to the caller.

Examples

Success:

use std::thread;
use pipe_channel::*;

let (mut tx, mut rx) = channel();
let handle = thread::spawn(move || {
    tx.send(35).unwrap();
    tx.send(42).unwrap();
});
assert_eq!(rx.recv().unwrap(), 35);
assert_eq!(rx.recv().unwrap(), 42);
handle.join().unwrap();

Failure:

use pipe_channel::*;
use std::sync::mpsc::SendError;
use std::mem::drop;

let (mut tx, rx) = channel();
drop(rx);
assert_eq!(tx.send(42), Err(SendError(42)));

Trait Implementations

impl<T> AsRawFd for Sender<T>[src]

impl<T> Debug for Sender<T>[src]

impl<T> Drop for Sender<T>[src]

impl<T> FromRawFd for Sender<T>[src]

impl<T> IntoRawFd for Sender<T>[src]

impl<T: Send> Send for Sender<T>[src]

Auto Trait Implementations

impl<T> RefUnwindSafe for Sender<T>

impl<T> !Sync for Sender<T>

impl<T> Unpin for Sender<T>

impl<T> UnwindSafe for Sender<T>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.