[−][src]Struct futures_intrusive::channel::shared::SharedStream
A stream that receives from channel using a GenericReceiver
.
Not driving the SharedStream
to completion after it has been polled
might lead to lost wakeup notifications.
Implementations
impl<MutexType, T, A> SharedStream<MutexType, T, A> where
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
[src]
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
pub fn close(&self) -> CloseStatus
[src]
Closes the channel. All pending and future send attempts will fail. Receive attempts will continue to succeed as long as there are items stored inside the channel. Further attempts will fail.
Trait Implementations
impl<MutexType: Debug, T: Debug, A: Debug> Debug for SharedStream<MutexType, T, A> where
MutexType: 'static + RawMutex,
T: 'static,
A: 'static + RingBuf<Item = T>,
[src]
MutexType: 'static + RawMutex,
T: 'static,
A: 'static + RingBuf<Item = T>,
impl<MutexType, T, A> FusedStream for SharedStream<MutexType, T, A> where
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
[src]
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
pub fn is_terminated(&self) -> bool
[src]
impl<MutexType, T, A> Stream for SharedStream<MutexType, T, A> where
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
[src]
MutexType: RawMutex,
A: 'static + RingBuf<Item = T>,
Auto Trait Implementations
impl<MutexType, T, A> !RefUnwindSafe for SharedStream<MutexType, T, A>
impl<MutexType, T, A> Send for SharedStream<MutexType, T, A> where
A: Send,
MutexType: Send + Sync,
T: Send,
A: Send,
MutexType: Send + Sync,
T: Send,
impl<MutexType, T, A> !Sync for SharedStream<MutexType, T, A>
impl<MutexType, T, A> !Unpin for SharedStream<MutexType, T, A>
impl<MutexType, T, A> !UnwindSafe for SharedStream<MutexType, T, A>
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,
pub 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<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.
pub 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>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<S, T, E> TryStream for S where
S: Stream<Item = Result<T, E>> + ?Sized,
[src]
S: Stream<Item = Result<T, E>> + ?Sized,