Struct SharedReceiver

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

The clone-able td::sync::mpsc::Receiver.

Messages sent to the channel can be retrieved using recv or try_recv.

Implementations

impl<T> SharedReceiver<T>

pub fn try_recv(&self) -> Result<T, TryRecvError>

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

pub fn iter(&self) -> Iter<'_, T>

Examples found in repository

examples/hello_server.rs (line 29)

fn worker(id: u32, chan: SharedReceiver<TcpStream>) {
    loop {
        for steam in chan.iter() {
            hello(id, steam);
        }
    }
}

Trait Implementations

impl<T> Clone for SharedReceiver<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, T> IntoIterator for &'a SharedReceiver<T>

type Item = T

The type of the elements being iterated over.

type IntoIter = Iter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Iter<'a, T>

Creates an iterator from a value.