Trait medea_reactive::subscribers_store::SubscribersStore

pub trait SubscribersStore<T, O>: Default {
    fn send_update(&self, value: T);
    fn subscribe(&self) -> LocalBoxStream<'static, O>;
#[must_use]    fn wrap(&self, value: T) -> O;
}

Store for updates subscribers.

Required methods

fn send_update(&self, value: T)

Sends data update to the all subscribers.

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

Creates new updates subscription.

Returns Stream yielding elements sent with SubscribersStore::send_update() calls.

#[must_use]fn wrap(&self, value: T) -> O

Wraps the provided value to the output type.

Loading content...

Implementors

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

fn send_update(&self, value: T)

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

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

impl<T> SubscribersStore<T, T> for medea_reactive::subscribers_store::common::SubStore<T> where
    T: Clone + 'static, 

fn send_update(&self, value: T)

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

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

Loading content...