-
Notifications
You must be signed in to change notification settings - Fork 47
/
tag.rs
66 lines (58 loc) · 1.47 KB
/
tag.rs
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
use dyn_clone::DynClone;
use std::any::Any;
use std::fmt;
use crate::runtime::Pmt;
use crate::runtime::StreamInput;
use crate::runtime::StreamOutput;
pub trait TagAny: Any + DynClone + Send + 'static {
fn as_any(&self) -> &dyn Any;
fn as_any_mut(&mut self) -> &mut dyn Any;
}
dyn_clone::clone_trait_object!(TagAny);
impl<T: Any + DynClone + Send + 'static> TagAny for T {
fn as_any(&self) -> &dyn Any {
self
}
fn as_any_mut(&mut self) -> &mut dyn Any {
self
}
}
impl dyn TagAny {
pub fn downcast_ref<T: TagAny>(&self) -> Option<&T> {
(*self).as_any().downcast_ref::<T>()
}
pub fn downcast_mut<T: TagAny>(&mut self) -> Option<&mut T> {
(*self).as_any_mut().downcast_mut::<T>()
}
}
impl fmt::Debug for Box<dyn TagAny> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(f, "Box<dyn Any>")
}
}
/// Stream tag
#[non_exhaustive]
#[derive(Clone, Debug)]
pub enum Tag {
/// Id
Id(u64),
/// String
String(String),
/// Pmt
Data(Pmt),
/// A `usize` with a name
NamedUsize(String, usize),
/// An `f32` with a name
NamedF32(String, f32),
/// Arbitrary data with a name
NamedAny(String, Box<dyn TagAny>),
}
/// Item tag
#[derive(Clone, Debug)]
pub struct ItemTag {
/// Index of sample in buffer
pub index: usize,
/// [`Tag`] value
pub tag: Tag,
}
pub fn default_tag_propagation(_inputs: &mut [StreamInput], _outputs: &mut [StreamOutput]) {}