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

use super::state::*;
use derive_more::{Deref, DerefMut};
use rill_engine::tracers::tracer::{timed, Tracer, Watcher};
use rill_protocol::io::provider::Path;

pub type FrameFlowWatcher<T> = Watcher<FrameFlowState<T>>;

/// It records time automatically.
#[derive(Debug, Deref, DerefMut, Clone)]
pub struct FrameFlowTracer<T: FrameFlowSpec> {
    tracer: Tracer<FrameFlowState<T>>,
}

impl<T: FrameFlowSpec> FrameFlowTracer<T> {
    pub fn new(path: Path, spec: T) -> (Self, FrameFlowWatcher<T>) {
        let state = FrameFlowState::new(spec);
        let (tracer, watcher) = Tracer::new_push(state, path);
        (Self { tracer }, watcher)
    }

    pub fn add_frame(&self, frame: T::Frame) {
        if let Some(event) = timed(frame) {
            let msg = FrameFlowEvent::AddFrame { event };
            self.tracer.send(msg, None);
        }
    }
}