Struct Receiver

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

The receiving-half of the sorted_channel type. This receiver can be cloned and sent to multiple threads. See Sender for an example.

Implementations

impl<T> Receiver<T>

pub fn recv(&self) -> Result<T, RecvError>

Wait for data in the channel by blocking the current thread, returning an error if there are no more Senders connected to this channel.

Examples

use sorted_channel::sorted_channel;
use std::thread;
let (tx, rx) = sorted_channel();
thread::spawn(move || {
    tx.send(7).unwrap();
});

assert_eq!(rx.recv(), Ok(7));

Failure from missing sender:

use sorted_channel::sorted_channel;
use std::thread;
let (tx, rx) = sorted_channel::<()>();
let handle = thread::spawn(move || {
    drop(tx);
});

handle.join().unwrap();
assert!(rx.recv().is_err());

Trait Implementations

impl<T> Clone for Receiver<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Drop for Receiver<T>

fn drop(&mut self)

Executes the destructor for this type.