[−][src]Struct futures_channel::mpsc::UnboundedReceiver
The receiving end of an unbounded mpsc channel.
This value is created by the unbounded
function.
Methods
impl<T> UnboundedReceiver<T>
[src]
pub fn close(&mut self)
[src]
Closes the receiving half of the channel, without dropping it.
This prevents any further messages from being sent on the channel while still enabling the receiver to drain messages that are buffered.
pub fn try_next(&mut self) -> Result<Option<T>, TryRecvError>
[src]
Tries to receive the next message without notifying a context if empty.
It is not recommended to call this function from inside of a future, only when you've otherwise arranged to be notified when the channel is no longer empty.
This function will panic if called after try_next
or poll_next
has
returned None.
Trait Implementations
impl<T> Unpin for UnboundedReceiver<T>
[src]
impl<T: Debug> Debug for UnboundedReceiver<T>
[src]
impl<T> Stream for UnboundedReceiver<T>
[src]
type Item = T
Values yielded by the stream.
fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<T>>
[src]
impl<T> FusedStream for UnboundedReceiver<T>
[src]
fn is_terminated(&self) -> bool
[src]
Auto Trait Implementations
impl<T> Send for UnboundedReceiver<T> where
T: Send,
T: Send,
impl<T> Sync for UnboundedReceiver<T> where
T: Send,
T: Send,
Blanket Implementations
impl<T> From for T
[src]
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom 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> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<S, T, E> TryStream for S where
S: Stream<Item = Result<T, E>>,
[src]
S: Stream<Item = Result<T, E>>,