Struct async_injector::Injector

pub struct Injector { /* fields omitted */ }

Use for handling injection.

Methods

impl Injector

pub fn new() -> Self

Create a new injector instance.

pub fn clear<T>(&self) where
    T: Clone + Any + Send + Sync + 'static, 

Clear the given value.

pub fn clear_key<T>(&self, key: &Key<T>) where
    T: Clone + Any + Send + Sync + 'static, 

Clear the given value.

pub fn update<T>(&self, value: T) where
    T: Any + Send + Sync + 'static + Clone, 

Set the given value and notify any subscribers.

pub fn update_key<T>(&self, key: &Key<T>, value: T) where
    T: Any + Send + Sync + 'static + Clone, 

Set the given value and notify any subscribers.

pub fn get<T>(&self) -> Option<T> where
    T: Any + Send + Sync + 'static + Clone, 

Get a value from the injector.

pub fn get_key<T>(&self, key: &Key<T>) -> Option<T> where
    T: Any + Send + Sync + 'static + Clone, 

Get a value from the injector with the given key.

pub fn stream<T>(&self) -> (Stream<T>, Option<T>) where
    T: Any + Send + Sync + 'static + Clone, 

Get an existing value and setup a stream for updates at the same time.

pub fn stream_key<T>(&self, key: &Key<T>) -> (Stream<T>, Option<T>) where
    T: Any + Send + Sync + 'static + Clone, 

Get an existing value and setup a stream for updates at the same time.

pub fn var<T>(&self) -> Result<Arc<RwLock<Option<T>>>, Error> where
    T: Any + Send + Sync + 'static + Clone + Unpin, 

Get a synchronized variable for the given configuration key.

pub fn var_key<T>(&self, key: &Key<T>) -> Result<Arc<RwLock<Option<T>>>, Error> where
    T: Any + Send + Sync + 'static + Clone + Unpin, 

Get a synchronized variable for the given configuration key.

pub async fn drive(self) -> Result<(), Error>

Run the injector as a future, making sure all asynchronous processes associated with it are driven to completion.

This has to be called for the injector to perform important tasks.

Trait Implementations

impl Clone for Injector

fn clone(&self) -> Injector

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.