aum-engine 0.1.0

Engine library for AUM
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

use aum_core::prelude::{Monitor, Storage, WalletManager};
pub struct Runtime<S: Storage, Wm: WalletManager, M: Monitor> {
    storage: S,
    scale: Wm,
    monitor: M,
}

impl<
    S: Storage + Send + 'static,
    Wm: WalletManager + Send + 'static,
    M: Monitor<WalletManager = Wm> + Send + 'static,
> Runtime<S, Wm, M>
{
    pub async fn new(storage: S, scale: Wm, monitor: M) -> Self {
        Self {
            storage,
            scale,
            monitor,
        }
    }
    pub fn run(mut self) {
        tokio::spawn(async move {
            if let Err(e) = self.monitor.start(&mut self.scale).await {
                panic!("Error starting monitor: {:?}", e);
            }
        });
    }
    pub fn storage(&self) -> &S {
        &self.storage
    }
    pub fn wallet_manager(&self) -> &Wm {
        &self.scale
    }
    pub fn monitor(&self) -> &M {
        &self.monitor
    }
}