Struct Waiter 

pub(crate) struct Waiter<'a, T>
where
    T: Storable + 'static,
{
    slot: Pin<&'a Slot<T>>,
    waiter: Waiter<'a>,
}

Fields

slot: Pin<&'a Slot<T>>

waiter: Waiter<'a>

Implementations

impl<'a, T> Waiter<'a, T>

where T: Storable + 'static,

pub(super) fn new(slot: Pin<&'a Slot<T>>, waiter: Waiter<'a>) -> Self

pub(crate) fn update_generation(&mut self)

Updates the last seen generation of this waiter so that we will wait for a newer value.

pub(crate) fn borrow(&self) -> Ref<'_, Option<T::DataType>>

pub(crate) fn read<U>(&self, f: impl FnOnce(&Option<T::DataType>) -> U) -> U

pub(crate) fn inner_type_name(&self) -> &'static str

pub(crate) async fn wait(&self)

impl<'a, T> Waiter<'a, T>

where T: Storable + 'static,

pub(crate) fn take( &mut self, span_context: Option<SpanContext>, ) -> Option<T::DataType>

Takes the current value of the slot, leaving behind None.

Stores the provided span_context to connect this write to the next read operation.

Trait Implementations

impl<T> Debug for Waiter<'_, T>

where T: Storable + 'static,

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

Formats the value using the given formatter.