Struct capitan_lib::services::IsolatedReactor

pub struct IsolatedReactor {
    pub services: Arc<RwLock<HashMap<usize, JoinHandle<Res<()>>>>>,
    pub notifier_channel: (UnboundedSender<bool>, UnboundedReceiver<bool>),
}

Contains and runs isolated services

Fields

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

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

Implementations

impl IsolatedReactor

pub fn new() -> Self

pub async fn wait_all(&mut self)

Trait Implementations

impl<T: IsolatedService + Send + Sync> IsolatedReactorTrait<T> for IsolatedReactor

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