zeebe 0.4.2

A rust client for defining, orchestrating, and monitoring business processes across microservices using Zeebe.
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

use std::any::{Any, TypeId};
use std::collections::HashMap;
use std::fmt;

mod extractor;
mod handler;

pub(crate) use extractor::FromJob;
pub use extractor::{Data, State};
pub(crate) use handler::HandlerFactory;

#[derive(Default)]
pub(crate) struct Extensions(HashMap<TypeId, Box<dyn Any>>);

impl Extensions {
    /// Build new default extensions
    pub(crate) fn new() -> Self {
        Extensions::default()
    }

    pub(crate) fn insert<T: 'static>(&mut self, data: T) {
        self.0.insert(data.type_id(), Box::new(data));
    }

    pub(crate) fn get<T: 'static>(&self) -> Option<&T> {
        self.0
            .get(&TypeId::of::<T>())
            .and_then(|boxed| (&**boxed as &(dyn Any + 'static)).downcast_ref())
    }
}

impl fmt::Debug for Extensions {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "Extensions {{ }}")
    }
}