roplat 0.1.0

roplat: just a robot operation system
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

mod event_trigger;
mod sys_timer;

use std::fmt::Debug;

pub use event_trigger::*;
pub use sys_timer::*;

use futures::future::BoxFuture;

use crate::RoplatError;

#[async_trait::async_trait]
pub trait Rhythm {
    type Yield;
    type Feed;

    type Output;
    type Error: Into<RoplatError> + Debug;

    async fn drive<N, F>(&mut self, mut nodes: N, op_domain: F) -> Self::Output
    where
        N: Send + Sync,
        F: for<'a> FnMut(&'a mut N, Self::Yield) -> BoxFuture<'a, Self::Feed> + Send;
    async fn init<N, F>(&mut self, _nodes: N, _init: F) -> Result<(), Self::Error>
    where
        N: Send,
        F: FnMut() + Send,
    {
        Ok(())
    }
    async fn shutdown<N, F>(&mut self, _nodes: N, _shutdown: F) -> Result<(), Self::Error>
    where
        N: Send,
        F: for<'a> FnMut(&'a mut N) + Send,
    {
        Ok(())
    }
}