maiko 0.3.1

Lightweight event-driven actor runtime with topic-based pub/sub for Tokio
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

use std::pin::Pin;

use tokio::time::Sleep;

use crate::internal::StepPause;

#[derive(Default)]
pub(crate) struct StepHandler {
    pub backoff: Option<Pin<Box<Sleep>>>,
    pub pause: StepPause,
}

impl StepHandler {
    pub fn is_delayed(&self) -> bool {
        self.backoff.is_some() && self.pause == StepPause::None
    }

    pub fn can_step(&self) -> bool {
        self.backoff.is_none() && self.pause == StepPause::None
    }

    pub fn reset(&mut self) {
        self.backoff = None;
        self.pause = StepPause::None;
    }
}