Struct Receiver 

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

Receiver end to receive message

Implements Future

Implementations

impl<T> Receiver<T>

pub fn is_ready(&self) -> bool

Returns whether job has been finished

pub fn is_consumed(&self) -> bool

Returns whether receiver has been ‘consumed’

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

Checks if message is received, returning it, if possible Otherwise returns None

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

Awaits message blocking until message arrives, returning it Or if Sender closes unexpectedly (e.g. due to panic) returns JoinError::Disconnect

pub fn recv_timeout(&self, time: Duration) -> Result<Option<T>, JoinError>

Awaits message blocking for the duration of time until message arrives, returning it Or if Sender closes unexpectedly (e.g. due to panic) returns JoinError::Disconnect

If timeout expires, returns Ok(None)

Trait Implementations

impl<T> Drop for Receiver<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Future for Receiver<T>

type Output = Result<T, JoinError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<T: Send> Send for Receiver<T>

impl<T> Unpin for Receiver<T>