wfe-core 1.9.2

Core traits, models, builder, and executor for the WFE workflow engine
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

use async_trait::async_trait;

use crate::models::ExecutionResult;
use crate::traits::step::{StepBody, StepExecutionContext};

type InlineFn = Box<dyn Fn() -> ExecutionResult + Send + Sync>;

/// A step that wraps an inline closure.
pub struct InlineStep {
    body: InlineFn,
}

impl InlineStep {
    pub fn new(f: impl Fn() -> ExecutionResult + Send + Sync + 'static) -> Self {
        Self { body: Box::new(f) }
    }
}

impl Default for InlineStep {
    fn default() -> Self {
        Self::new(ExecutionResult::next)
    }
}

#[async_trait]
impl StepBody for InlineStep {
    async fn run(&mut self, _context: &StepExecutionContext<'_>) -> crate::Result<ExecutionResult> {
        Ok((self.body)())
    }
}