gearbox 3.0.0

Excessive tooling for Rust, boosting productivity and operations
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

use crate::error::tracer::DynTracerError;
use crate::task::multicommand::command_response::CommandResponse;
use crate::task::multicommand::ExecutableCommand;
use alloc::{boxed::Box, string::String, vec, vec::Vec};
use core::{
    fmt::{self, *},
    future::Future,
    pin::Pin,
    result::Result,
};
use tokio::task;
use tokio::task::JoinHandle;

pub struct Function(Box<dyn FnOnce(&mut CommandResponse) + Send>);

impl Function {
    pub fn new<F: FnOnce(&mut CommandResponse) + Send + 'static>(f: F) -> Self {
        Self(Box::new(f))
    }
}

impl ExecutableCommand for Function {
    fn exec(
        self,
        id: Option<String>,
    ) -> Pin<Box<dyn Future<Output = Vec<JoinHandle<Result<CommandResponse, DynTracerError>>>>>>
    {
        Box::pin(async {
            vec![task::spawn(async move {
                let mut resp = CommandResponse::new();
                resp.with_task_id(id);
                (self.0)(&mut resp);
                Ok(resp)
            })]
        })
    }
}

impl Debug for Function {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "Function Command")
    }
}