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

use super::state::*;
use derive_more::{Deref, DerefMut};
use rill_engine::tracers::tracer::{Tracer, Watcher};

pub type MetaFlowWatcher<T> = Watcher<MetaFlowState<T>>;

#[derive(Debug, Deref, DerefMut, Clone)]
pub struct MetaFlowTracer<T: MetaFlowSpec> {
    tracer: Tracer<MetaFlowState<T>>,
}

impl<T: MetaFlowSpec> MetaFlowTracer<T> {
    pub fn new() -> (Self, MetaFlowWatcher<T>) {
        let state = MetaFlowState::new();
        let (tracer, watcher) = Tracer::new_push(state, T::path());
        (Self { tracer }, watcher)
    }

    pub fn set_meta(&self, meta: T::Meta) {
        let msg = MetaFlowEvent::SetMeta { meta };
        self.tracer.send(msg, None);
    }

    pub fn clear(&self) {
        let msg = MetaFlowEvent::Clear;
        self.tracer.send(msg, None);
    }
}