Struct ReceiverInner

struct ReceiverInner<T: Debug + Send + 'static, C: ChannelSpec> {
    state: Mutex<Result<ReceiverState<T, C>, CollapsedDueToReclaim>>,
}

Payload of Receiver, that’s within the Arc, but contains the Mutex.

This is a separate type because it’s what we need to implement IsParticipant for.

Fields

state: Mutex<Result<ReceiverState<T, C>, CollapsedDueToReclaim>>

Mutable state

If we have collapsed due to memory reclaim, state is replaced by an Err. In that case the caller mostly can’t send on the Sender either, because we’ll have torn down the Participant, so claims (beyond the cache in the Sender’s Participation) will fail.

Implementations

impl<T: Debug + Send + 'static, C: ChannelSpec> ReceiverInner<T, C>

fn lock( &self, ) -> MutexGuard<'_, Result<ReceiverState<T, C>, CollapsedDueToReclaim>>

Convenience function to take the lock

Trait Implementations

impl<T: Debug + Send + 'static, C: ChannelSpec> Debug for ReceiverInner<T, C>

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: HasMemoryCost + Debug + Send + 'static, C: ChannelSpec> IsParticipant for ReceiverInner<T, C>

fn get_oldest(&self, _: EnabledToken) -> Option<CoarseInstant>

Return the age of the oldest data held by this Participant

fn reclaim(self: Arc<Self>, _: EnabledToken) -> ReclaimFuture

Start memory reclamation