trellis-core 0.1.2

Deterministic reactive resource graph core types.
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

use crate::collection::{
    CollectionContext, CollectionSpec, MapCollectionShape, SetCollectionShape,
};
use crate::input::value_type;
use crate::{CollectionNode, DependencyList, Graph, GraphResult, NodeId, NodeKind, NodeMeta};
use std::collections::{BTreeMap, BTreeSet};

impl<C: 'static, O> Graph<C, O> {
    pub(crate) fn collection_map_direct<K, V>(
        &mut self,
        id: NodeId,
        debug_name: impl Into<String>,
        dependencies: DependencyList,
        derive: impl for<'ctx> Fn(
            &CollectionContext<'ctx, C, O>,
        ) -> Result<BTreeMap<K, V>, crate::DeriveError>
        + Send
        + Sync
        + 'static,
    ) -> GraphResult<CollectionNode<K, V>>
    where
        K: Clone + Ord + Send + Sync + 'static,
        V: Clone + PartialEq + Send + Sync + 'static,
    {
        self.validate_dependencies(id, &dependencies)?;
        let meta = NodeMeta::new(
            id,
            NodeKind::Collection,
            debug_name,
            dependencies,
            self.revision,
            Some(value_type::<MapCollectionShape<K, V>>()),
        );
        self.nodes.insert(id, meta);
        self.collection_specs
            .insert(id, CollectionSpec::<C, O>::map(derive));
        Ok(CollectionNode::new(id))
    }

    pub(crate) fn collection_set_direct<K>(
        &mut self,
        id: NodeId,
        debug_name: impl Into<String>,
        dependencies: DependencyList,
        derive: impl for<'ctx> Fn(
            &CollectionContext<'ctx, C, O>,
        ) -> Result<BTreeSet<K>, crate::DeriveError>
        + Send
        + Sync
        + 'static,
    ) -> GraphResult<CollectionNode<K, ()>>
    where
        K: Clone + Ord + Send + Sync + 'static,
    {
        self.validate_dependencies(id, &dependencies)?;
        let meta = NodeMeta::new(
            id,
            NodeKind::Collection,
            debug_name,
            dependencies,
            self.revision,
            Some(value_type::<SetCollectionShape<K>>()),
        );
        self.nodes.insert(id, meta);
        self.collection_specs
            .insert(id, CollectionSpec::<C, O>::set(derive));
        Ok(CollectionNode::new(id))
    }
}