Struct ConfigUpdates

pub struct ConfigUpdates { /* private fields */ }

Implementations

impl ConfigUpdates

pub fn for_listener<A>(addr: impl ToAddress<A>) -> Self

where A: OnEvent<NewConfig>,

Methods from Deref<Target = Recipient<NewConfig>>

pub fn reform<F, IN>(&self, func: F) -> Recipient<IN>

where F: Fn(IN) -> M + Send + Sync + 'static, M: 'static,

Changes Recipient to another input type.

Trait Implementations

impl Deref for ConfigUpdates

type Target = Recipient<NewConfig>

The resulting type after dereferencing.

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

Dereferences the value.

impl DerefMut for ConfigUpdates

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl ManageSubscription<ConfigUpdates> for ConfigLoader

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 mut self, sub_id: UniqueId<ConfigUpdates>, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 mut self, sub_id: UniqueId<ConfigUpdates>, _ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Subscribe<S>, ctx: &'life1 mut Context<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

impl Subscription for ConfigUpdates

type State = Value