[−][src]Struct futures_intrusive::channel::shared::GenericReceiver
The receiving side of a channel which can be used to exchange values between concurrent tasks.
Tasks can receive values from the channel through the receive
method.
The returned Future will get resolved when a value is sent into the channel.
Methods
impl<MutexType, T> GenericReceiver<MutexType, T> where
MutexType: RawMutex + 'static,
[src]
MutexType: RawMutex + 'static,
ⓘImportant traits for ChannelReceiveFuture<MutexType, T>pub fn receive(&self) -> ChannelReceiveFuture<MutexType, T>
[src]
ⓘImportant traits for ChannelReceiveFuture<MutexType, T>
Returns a future that gets fulfilled when a value is written to the channel.
If the channels gets closed, the future will resolve to None
.
pub fn close(&self)
[src]
Closes the channel.
All pending future send attempts will fail.
Receive attempts will continue to succeed as long as there are items
stored inside the channel. Further attempts will return None
.
Trait Implementations
impl<MutexType, T> Drop for GenericReceiver<MutexType, T> where
MutexType: RawMutex,
[src]
MutexType: RawMutex,
impl<MutexType, T> Clone for GenericReceiver<MutexType, T> where
MutexType: RawMutex,
[src]
MutexType: RawMutex,
fn clone(&self) -> Self
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<MutexType, T> Debug for GenericReceiver<MutexType, T> where
MutexType: RawMutex,
[src]
MutexType: RawMutex,
Auto Trait Implementations
impl<MutexType, T> Send for GenericReceiver<MutexType, T> where
MutexType: Send + Sync,
T: Send,
MutexType: Send + Sync,
T: Send,
impl<MutexType, T> Sync for GenericReceiver<MutexType, T> where
MutexType: Send + Sync,
T: Send,
MutexType: Send + Sync,
T: Send,
impl<MutexType, T> Unpin for GenericReceiver<MutexType, T>
impl<MutexType, T> !UnwindSafe for GenericReceiver<MutexType, T>
impl<MutexType, T> !RefUnwindSafe for GenericReceiver<MutexType, T>
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[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>,
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> 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> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,