pub struct ChannelStream<'a, MutexType: RawMutex, T, A>where
A: RingBuf<Item = T>,{ /* private fields */ }
Expand description
A stream that receives from a GenericChannel
.
Not driving the ChannelStream
to completion after it has been polled
might lead to lost wakeup notifications.
Trait Implementations§
Source§impl<'a, MutexType: Debug + RawMutex, T: Debug, A> Debug for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType: Debug + RawMutex, T: Debug, A> Debug for ChannelStream<'a, MutexType, T, A>
Source§impl<'a, MutexType, T, A> FusedStream for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> FusedStream for ChannelStream<'a, MutexType, T, A>
Source§fn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
Returns
true
if the stream should no longer be polled.Source§impl<'a, MutexType, T, A> Stream for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> Stream for ChannelStream<'a, MutexType, T, A>
Auto Trait Implementations§
impl<'a, MutexType, T, A> Freeze for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> !RefUnwindSafe for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> Send for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> !Sync for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> !Unpin for ChannelStream<'a, MutexType, T, A>
impl<'a, MutexType, T, A> !UnwindSafe for ChannelStream<'a, MutexType, T, A>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more