organix 0.1.3

Building organic application in rust, leveraging tokio and defining inter communication layer mechanism
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use crate::{
    runtime::Runtimes,
    watchdog::{ControlCommand, WatchdogQuery},
};
use std::future::Future;
use tokio::{
    sync::{mpsc, oneshot},
    task::JoinHandle,
};

pub struct WatchdogMonitor {
    runtimes: Runtimes,
    control_command: mpsc::Sender<ControlCommand>,
    watchdog_finished: oneshot::Receiver<()>,
}

impl WatchdogMonitor {
    pub(crate) fn new(
        runtimes: Runtimes,
        control_command: mpsc::Sender<ControlCommand>,
        watchdog_finished: oneshot::Receiver<()>,
    ) -> Self {
        WatchdogMonitor {
            runtimes,
            control_command,
            watchdog_finished,
        }
    }

    pub fn control(&self) -> WatchdogQuery {
        WatchdogQuery::new(
            self.runtimes.watchdog().handle().clone(),
            self.control_command.clone(),
        )
    }

    pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>
    where
        F: Future + Send + 'static,
        F::Output: Send + 'static,
    {
        self.runtimes.watchdog().handle().spawn(future)
    }

    pub fn wait_finished(self) {
        let Self {
            mut runtimes,
            watchdog_finished,
            ..
        } = self;

        runtimes
            .watchdog_mut()
            .block_on(async move { watchdog_finished.await.unwrap() })
    }
}