lash-core 0.1.0-alpha.37

Sans-IO turn machine and runtime kernel for the lash agent runtime.
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

use std::sync::Arc;

use crate::PluginFactory;

#[derive(Clone, Default)]
pub struct PluginStack {
    factories: Vec<Arc<dyn PluginFactory>>,
}

impl PluginStack {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn from_factories(factories: impl IntoIterator<Item = Arc<dyn PluginFactory>>) -> Self {
        Self {
            factories: factories.into_iter().collect(),
        }
    }

    pub fn factories(&self) -> &[Arc<dyn PluginFactory>] {
        &self.factories
    }

    pub fn into_factories(self) -> Vec<Arc<dyn PluginFactory>> {
        self.factories
    }

    pub fn push(&mut self, plugin: Arc<dyn PluginFactory>) -> &mut Self {
        self.factories.push(plugin);
        self
    }

    pub fn extend(
        &mut self,
        plugins: impl IntoIterator<Item = Arc<dyn PluginFactory>>,
    ) -> &mut Self {
        self.factories.extend(plugins);
        self
    }

    pub fn remove(&mut self, id: &str) -> &mut Self {
        self.factories.retain(|plugin| plugin.id() != id);
        self
    }

    pub fn replace(&mut self, plugin: Arc<dyn PluginFactory>) -> &mut Self {
        let id = plugin.id();
        if let Some(slot) = self
            .factories
            .iter_mut()
            .find(|existing| existing.id() == id)
        {
            *slot = plugin;
        } else {
            self.factories.push(plugin);
        }
        self
    }

    pub fn retain(&mut self, keep: impl FnMut(&Arc<dyn PluginFactory>) -> bool) -> &mut Self {
        self.factories.retain(keep);
        self
    }

    pub fn configure(mut self, configure: impl FnOnce(&mut PluginStack)) -> Self {
        configure(&mut self);
        self
    }
}