Struct postage::oneshot::Receiver

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

The receiver half of a oneshot channel. Can recieve a single message (or none if the sender drops) with the postage::Stream trait.

Trait Implementations

impl<T> Debug for Receiver<T>

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

Formats the value using the given formatter.

impl<T> Drop for Receiver<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Stream for Receiver<T>

type Item = T

fn poll_recv(self: Pin<&mut Self>, cx: &mut Context<'_>) -> PollRecv<Self::Item>

Attempts to retrieve an item from the stream, without blocking.

fn recv(&mut self) -> RecvFuture<'_, Self> where
    Self: Unpin, 

Retrieves a message from the stream.

fn try_recv(&mut self) -> Result<Self::Item, TryRecvError> where
    Self: Unpin, 

Attempts to retrive a message from the stream, without blocking.

fn blocking_recv(&mut self) -> Option<Self::Item> where
    Self: Unpin, 

Retrieves a message from the stream, blocking the current thread until one is available.

fn map<Map, Into>(self, map: Map) -> MapStream<Self, Map, Into> where
    Map: Fn(Self::Item) -> Into,
    Self: Sized, 

Transforms the stream with a map function.

fn filter<Filter>(self, filter: Filter) -> FilterStream<Self, Filter> where
    Self: Sized + Unpin,
    Filter: FnMut(&Self::Item) -> bool + Unpin, 

Filters messages returned by the stream, ignoring messages where filter returns false.

fn merge<Other>(self, other: Other) -> MergeStream<Self, Other> where
    Other: Stream<Item = Self::Item>,
    Self: Sized, 

Merges two streams, returning values from both at once, until both are closed.

fn chain<Other>(self, other: Other) -> ChainStream<Self, Other> where
    Other: Stream<Item = Self::Item>,
    Self: Sized, 

Chains two streams, returning values from self until it is closed, and then returning values from other.

fn find<Condition>(self, condition: Condition) -> FindStream<Self, Condition> where
    Self: Sized + Unpin,
    Condition: Fn(&Self::Item) -> bool + Unpin, 

Finds a message matching a condition. When the condition is matched, a single value will be returned. Then the stream will be closed.

fn log(self, level: Level) -> StreamLog<Self> where
    Self: Sized,
    Self::Item: Debug, 

Logs messages that are produced by the stream using the Debug trait, at the provided log level.