Struct SharedReactor

pub struct SharedReactor<T: SharedService + Send + Sync> {
    pub services: Arc<RwLock<HashMap<usize, Arc<(Arc<T>, JoinHandle<Result<()>>)>>>>,
    pub notifier_channel: (UnboundedSender<bool>, UnboundedReceiver<bool>),
}

Contains and runs shared services

Fields

services: Arc<RwLock<HashMap<usize, Arc<(Arc<T>, JoinHandle<Result<()>>)>>>>

notifier_channel: (UnboundedSender<bool>, UnboundedReceiver<bool>)

Implementations

impl<T: SharedService + Send + Sync> SharedReactor<T>

pub fn new() -> Self

pub async fn wait_all(&mut self)

Trait Implementations

impl<T: SharedService + Send + Sync> SharedReactorTrait<T> for SharedReactor<T>

fn spawn_service<'life0, 'async_trait>( &'life0 self, service: T, id: usize, ) -> Pin<Box<dyn Future<Output = Res<()>> + Send + 'async_trait>>

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

fn get_service<'life0, 'async_trait>( &'life0 self, id: usize, ) -> Pin<Box<dyn Future<Output = Option<Weak<T>>> + Send + 'async_trait>>

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