Struct medea_reactive::subscribers_store::progressable::guarded::Guarded

pub struct Guarded<T> { /* private fields */ }

Wrapper around a data T decrementing its underlying counter on Drop.

Implementations

impl<T> Guarded<T>

pub fn into_parts(self) -> (T, Guard)

Unwraps this Guarded into its inner value and its Guard.

pub fn into_inner(self) -> T

Unwraps this Guarded into its inner value dropping its Guard in-place.

impl<T> Guarded<Option<T>>

pub fn transpose(self) -> Option<Guarded<T>>

Transposes an Guarded Option into a Option with a Guarded value within.

Trait Implementations

impl<T> AsRef<T> for Guarded<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.

impl<T: Debug> Debug for Guarded<T>

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

Formats the value using the given formatter.

impl<T> Deref for Guarded<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> SubscribersStore<T, Guarded<T>> for SubStore<T>where T: Clone + 'static,

fn send_update(&self, value: T)

Sends data update to the all subscribers.

fn subscribe(&self) -> LocalBoxStream<'static, Guarded<T>>

Creates new updates subscription.

fn wrap(&self, value: T) -> Guarded<T>

Wraps the provided value to the output type.