Struct oneshot::Receiver

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

Implementations§

source§

impl<T> Receiver<T>

source

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

Checks if there is a message in the channel without blocking. Returns:

  • Ok(message) if there was a message in the channel.
  • Err(Empty) if the Sender is alive, but has not yet sent a message.
  • Err(Disconnected) if the Sender was dropped before sending anything or if the message has already been extracted by a previous receive call.

If a message is returned, the channel is disconnected and any subsequent receive operation using this receiver will return an error.

This method is completely lock-free and wait-free. The only thing it does is an atomic integer load of the channel state. And if there is a message in the channel it additionally performs one atomic integer store and copies the message from the heap to the stack for returning it.

source

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

Attempts to wait for a message from the Sender, returning an error if the channel is disconnected.

This method will always block the current thread if there is no data available and it is still possible for the message to be sent. Once the message is sent to the corresponding Sender, then this receiver will wake up and return that message.

If the corresponding Sender has disconnected (been dropped), or it disconnects while this call is blocking, this call will wake up and return Err to indicate that the message can never be received on this channel.

If a sent message has already been extracted from this channel this method will return an error.

§Panics

Panics if called after this receiver has been polled asynchronously.

source

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

Attempts to wait for a message from the Sender, returning an error if the channel is disconnected. This is a non consuming version of Receiver::recv, but with a bit worse performance. Prefer [Receiver::recv] if your code allows consuming the receiver.

If a message is returned, the channel is disconnected and any subsequent receive operation using this receiver will return an error.

§Panics

Panics if called after this receiver has been polled asynchronously.

source

pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError>

Like Receiver::recv, but will not block longer than timeout. Returns:

  • Ok(message) if there was a message in the channel before the timeout was reached.
  • Err(Timeout) if no message arrived on the channel before the timeout was reached.
  • Err(Disconnected) if the sender was dropped before sending anything or if the message has already been extracted by a previous receive call.

If a message is returned, the channel is disconnected and any subsequent receive operation using this receiver will return an error.

If the supplied timeout is so large that Rust’s Instant type can’t represent this point in the future this falls back to an indefinitely blocking receive operation.

§Panics

Panics if called after this receiver has been polled asynchronously.

source

pub fn recv_deadline(&self, deadline: Instant) -> Result<T, RecvTimeoutError>

Like Receiver::recv, but will not block longer than until deadline. Returns:

  • Ok(message) if there was a message in the channel before the deadline was reached.
  • Err(Timeout) if no message arrived on the channel before the deadline was reached.
  • Err(Disconnected) if the sender was dropped before sending anything or if the message has already been extracted by a previous receive call.

If a message is returned, the channel is disconnected and any subsequent receive operation using this receiver will return an error.

§Panics

Panics if called after this receiver has been polled asynchronously.

source

pub fn into_raw(self) -> *mut ()

Consumes the Receiver, returning a raw pointer to the channel on the heap.

This is intended to simplify using oneshot channels with some FFI code. The only safe thing to do with the returned pointer is to later reconstruct the Receiver with Receiver::from_raw. Memory will leak if the Receiver is never reconstructed.

source

pub unsafe fn from_raw(raw: *mut ()) -> Self

Consumes a raw pointer from Receiver::into_raw, recreating the Receiver.

§Safety

This pointer must have come from Receiver<T>::into_raw with the same message type, T. At most one Receiver must exist for a channel at any point in time. Constructing multiple Receivers from the same raw pointer leads to undefined behavior.

Trait Implementations§

source§

impl<T: Debug> Debug for Receiver<T>

source§

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

Formats the value using the given formatter. Read more
source§

impl<T> Drop for Receiver<T>

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl<T> Future for Receiver<T>

§

type Output = Result<T, RecvError>

The type of value produced on completion.
source§

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

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more
source§

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

source§

impl<T> Unpin for Receiver<T>

Auto Trait Implementations§

§

impl<T> Freeze for Receiver<T>

§

impl<T> !RefUnwindSafe for Receiver<T>

§

impl<T> !Sync for Receiver<T>

§

impl<T> !UnwindSafe for Receiver<T>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<F> IntoFuture for F
where F: Future,

§

type Output = <F as Future>::Output

The output that the future will produce on completion.
§

type IntoFuture = F

Which kind of future are we turning this into?
source§

fn into_future(self) -> <F as IntoFuture>::IntoFuture

Creates a future from a value. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

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

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.