Struct MetaService 

pub struct MetaService<S: ?Sized = dyn MetaSource> { /* private fields */ }

Service for managing the caching of meta fields.

Implementations

impl<S: MetaSource + ?Sized> MetaService<S>

pub fn new(source: S) -> Arc<MetaService>

where S: Sized,

pub async fn get_field<V: DeserializeOwned + 'static>( &self, db: &Database, field: &str, ) -> Option<MetaValue<V>>

Get the value for the meta field.

This may wait for significant time on first run.

pub async fn entries(&self, db: &Database) -> Option<MetaEntries>

Get all meta entries.

This may wait for significant time on first run when there is no cached data.

pub async fn wait_initialization(&self)

Wait until Meta Service is initialized, after this get_field will not block.

pub fn subscribe_to_updates(&self) -> impl Stream<Item = ()> + '_

NOTE: this subscription never ends even after update task is shutdown. You should consume this stream in a spawn_cancellable.

pub fn subscribe_to_field<'a, V: DeserializeOwned + 'static>( &'a self, db: &'a Database, name: &'a str, ) -> impl Stream<Item = Option<MetaValue<V>>> + 'a

NOTE: this subscription never ends even after update task is shutdown. You should consume this stream in a spawn_cancellable.

Stream will yield the first element immediately without blocking. The first element will be initial value of the field.

This may yield an outdated initial value if you didn’t call Self::wait_initialization.