rillrate-protocol 0.36.0

Top level protocol for the RillRate protocol.
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

use rill_protocol::flow::core::{DataFraction, Flow};
use rill_protocol::io::provider::{Path, StreamType};
use serde::{Deserialize, Serialize};

// TODO: Use list instead?
pub trait MetaFlowSpec: DataFraction {
    type Meta: DataFraction;

    fn path() -> Path;
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct MetaFlowState<T: MetaFlowSpec> {
    pub meta: Option<T::Meta>,
}

#[allow(clippy::new_without_default)]
impl<T: MetaFlowSpec> MetaFlowState<T> {
    pub fn new() -> Self {
        Self { meta: None }
    }
}

impl<T: MetaFlowSpec> Flow for MetaFlowState<T> {
    type Action = MetaFlowAction;
    type Event = MetaFlowEvent<T>;

    fn stream_type() -> StreamType {
        StreamType::from(module_path!())
    }

    fn apply(&mut self, event: Self::Event) {
        match event {
            MetaFlowEvent::SetMeta { meta } => {
                self.meta = Some(meta);
            }
            MetaFlowEvent::Clear => {
                self.meta.take();
            }
        }
    }
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum MetaFlowAction {}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum MetaFlowEvent<T: MetaFlowSpec> {
    SetMeta { meta: T::Meta },
    Clear,
}