[−][src]Struct futures_intrusive::channel::shared::GenericStateReceiver
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.
Implementations
impl<MutexType, T> GenericStateReceiver<MutexType, T> where
MutexType: RawMutex + 'static,
T: Clone,
[src]
MutexType: RawMutex + 'static,
T: Clone,
pub fn receive(&self, state_id: StateId) -> StateReceiveFuture<MutexType, T>ⓘNotable traits for StateReceiveFuture<MutexType, T>
impl<MutexType, T> Future for StateReceiveFuture<MutexType, T> type Output = Option<(StateId, T)>;
[src]
Notable traits for StateReceiveFuture<MutexType, T>
impl<MutexType, T> Future for StateReceiveFuture<MutexType, T> type Output = Option<(StateId, T)>;
Returns a future that gets fulfilled when a value is written to the channel
or the channel is closed.
state_id
specifies the minimum state ID that should be retrieved
by the receive
operation.
The returned StateReceiveFuture
will get fulfilled with the
retrieved value as well as the StateId
which is required to retrieve
the following state
pub fn try_receive(&self, state_id: StateId) -> Option<(StateId, T)>
[src]
Attempt to retrieve a value whose StateId
is greater than the one provided.
Returns None
if no value is found in the channel, or if the current StateId
of the value is less or equal to the one provided.
Trait Implementations
impl<MutexType, T> Clone for GenericStateReceiver<MutexType, T> where
MutexType: RawMutex,
T: Clone,
[src]
MutexType: RawMutex,
T: Clone,
pub fn clone(&self) -> Self
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl<MutexType, T> Debug for GenericStateReceiver<MutexType, T> where
MutexType: RawMutex,
T: Clone,
[src]
MutexType: RawMutex,
T: Clone,
impl<MutexType, T> Drop for GenericStateReceiver<MutexType, T> where
MutexType: RawMutex,
T: Clone,
[src]
MutexType: RawMutex,
T: Clone,
Auto Trait Implementations
impl<MutexType, T> !RefUnwindSafe for GenericStateReceiver<MutexType, T>
impl<MutexType, T> Send for GenericStateReceiver<MutexType, T> where
MutexType: Send + Sync,
T: Send,
MutexType: Send + Sync,
T: Send,
impl<MutexType, T> Sync for GenericStateReceiver<MutexType, T> where
MutexType: Send + Sync,
T: Send,
MutexType: Send + Sync,
T: Send,
impl<MutexType, T> Unpin for GenericStateReceiver<MutexType, T>
impl<MutexType, T> !UnwindSafe for GenericStateReceiver<MutexType, T>
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> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub 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.
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>,