snurr 0.6.1

Read BPMN 2.0 files and run the process flow
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

use std::{
    sync::mpsc::{channel, Sender},
    thread::{self, JoinHandle},
};

pub(super) struct Trace<T> {
    sender: Sender<T>,
    handle: JoinHandle<Vec<T>>,
}

impl<T> Trace<T> {
    pub(super) fn sender(&self) -> Sender<T> {
        self.sender.clone()
    }

    pub(super) fn finish(self) -> Vec<T> {
        drop(self.sender);
        self.handle.join().expect("oops! the child thread panicked")
    }
}

pub(super) fn tracer<T: Send + 'static>() -> Trace<T> {
    let (sender, receiver) = channel();

    // Collect the name or id for the path taken
    let recv_handle = thread::spawn(move || {
        let mut trace = vec![];
        while let Ok(value) = receiver.recv() {
            trace.push(value);
        }
        trace
    });
    Trace {
        sender,
        handle: recv_handle,
    }
}