[−][src]Struct flume::Receiver
The receiving end of a channel.
Methods
impl<T> Receiver<T>
[src]
pub fn recv(&self) -> Result<T, RecvError>
[src]
Wait for an incoming value on this receiver, returning an error if all channel senders have been dropped.
pub fn recv_timeout(&self, timeout: Duration) -> Result<T, RecvTimeoutError>
[src]
Wait for an incoming value on this receiver, returning an error if all channel senders have been dropped or the timeout has expired.
pub fn recv_deadline(&self, deadline: Instant) -> Result<T, RecvTimeoutError>
[src]
Wait for an incoming value on this receiver, returning an error if all channel senders have been dropped or the deadline has passed.
pub fn try_recv(&self) -> Result<T, TryRecvError>
[src]
Attempt to fetch an incoming value on this receiver, returning an error if the channel is empty or all channel senders have been dropped.
pub fn iter(&self) -> impl Iterator<Item = T> + '_
[src]
A blocking iterator over the values received on the channel that finishes iteration when all receivers of the channel have been dropped.
pub fn try_iter(&self) -> impl Iterator<Item = T> + '_
[src]
A non-blocking iterator over the values received on the channel that finishes iteration when all receivers of the channel have been dropped or the channel is empty.
Trait Implementations
Auto Trait Implementations
impl<T> !RefUnwindSafe for Receiver<T>
impl<T> Send for Receiver<T> where
T: Send,
T: Send,
impl<T> !Sync for Receiver<T>
impl<T> Unpin for Receiver<T>
impl<T> !UnwindSafe for Receiver<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<I> IntoIterator for I where
I: Iterator,
[src]
I: Iterator,
type Item = <I as Iterator>::Item
The type of the elements being iterated over.
type IntoIter = I
Which kind of iterator are we turning this into?
fn into_iter(self) -> I
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,