Struct flume::async::RecvStream
source · [−]pub struct RecvStream<'a, T>(_);
Expand description
A stream which allows asynchronously receiving messages.
Can be created via Receiver::stream
or Receiver::into_stream
.
Implementations
sourceimpl<'a, T> RecvStream<'a, T>
impl<'a, T> RecvStream<'a, T>
sourcepub fn is_disconnected(&self) -> bool
pub fn is_disconnected(&self) -> bool
sourcepub fn is_empty(&self) -> bool
pub fn is_empty(&self) -> bool
See Receiver::is_empty
.
sourcepub fn is_full(&self) -> bool
pub fn is_full(&self) -> bool
See Receiver::is_full
.
sourcepub fn len(&self) -> usize
pub fn len(&self) -> usize
See Receiver::len
.
sourcepub fn capacity(&self) -> Option<usize>
pub fn capacity(&self) -> Option<usize>
See Receiver::capacity
.
Trait Implementations
sourceimpl<'a, T> Clone for RecvStream<'a, T>
impl<'a, T> Clone for RecvStream<'a, T>
sourcefn clone(&self) -> RecvStream<'a, T>
fn clone(&self) -> RecvStream<'a, T>
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl<'a, T> FusedStream for RecvStream<'a, T>
impl<'a, T> FusedStream for RecvStream<'a, T>
sourcefn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
Returns true
if the stream should no longer be polled.
sourceimpl<'a, T> Stream for RecvStream<'a, T>
impl<'a, T> Stream for RecvStream<'a, T>
type Item = T
type Item = T
Values yielded by the stream.
Auto Trait Implementations
impl<'a, T> !RefUnwindSafe for RecvStream<'a, T>
impl<'a, T> Send for RecvStream<'a, T> where
T: Send,
impl<'a, T> Sync for RecvStream<'a, T> where
T: Send,
impl<'a, T> Unpin for RecvStream<'a, T>
impl<'a, T> !UnwindSafe for RecvStream<'a, T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more