studiole-command 0.4.1

A simple command execution framework with event subscription and progress tracking.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use crate::prelude::*;
use std::time::Duration;
use tokio::time::sleep;

#[derive(Debug)]
pub struct DelayHandler;

impl FromServicesAsync for DelayHandler {
    type Error = Infallible;

    async fn from_services_async(_services: &ServiceProvider) -> Result<Self, Report<Self::Error>> {
        Ok(Self)
    }
}

#[async_trait]
impl Execute<DelayRequest, (), Infallible> for DelayHandler {
    async fn execute(&self, request: &DelayRequest) -> Result<(), Infallible> {
        debug!(%request, "Executing {} ms delay", request.duration);
        sleep(Duration::from_millis(request.duration)).await;
        Ok(())
    }
}