jobflow 0.3.0

Executes jobs in order
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

//! Listens to [`Flow`](crate::Flow) events

use crate::{FlowError, JobError, JobId};

/// Listens to a [`Flow`] instance.
pub trait FlowListener {
    /// Ran as a flow starts
    fn started(&mut self) {}

    /// A task started
    fn task_started(&mut self, id: JobId, nickname: &str) {
        let _id = id;
        let _nickname = nickname;
    }

    /// A task finished
    fn task_finished(&mut self, id: JobId, nickname: &str, result: Result<(), &JobError>) {
        let _id = id;
        let _nickname = nickname;
        let _result = result;
    }
    /// Ran once the entire flow is done
    fn finished(&mut self, result: Result<(), &FlowError>) {
        let _ = result;
    }
}

pub struct PrintTaskListener;

impl FlowListener for PrintTaskListener {
    fn task_started(&mut self, _id: JobId, nickname: &str) {
        println!("== started: {} ==", nickname);
    }

    fn task_finished(&mut self, _id: JobId, nickname: &str, result: Result<(), &JobError>) {
        println!("== finished: {}. {result:?} ==", nickname);
    }
}