indicator 0.4.4

Abstractions for stream aggregation, we call them `Indicator` s.
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

use crate::context::ValueRef;

use super::FromValueRef;

/// Extract from the data context.
pub struct Data<T>(pub T);

impl<'a, I, T> FromValueRef<'a, I> for Data<&'a T>
where
    T: Send + Sync + 'static,
{
    #[inline]
    fn from_value_ref(value: &ValueRef<'a, I>) -> Self {
        Self(value.context.data().get::<T>().unwrap_or_else(|| {
            panic!(
                "`{}` not found in the data context",
                core::any::type_name::<T>()
            )
        }))
    }
}

impl<'a, I, T> FromValueRef<'a, I> for Data<Option<&'a T>>
where
    T: Send + Sync + 'static,
{
    #[inline]
    fn from_value_ref(value: &ValueRef<'a, I>) -> Self {
        Self(value.context.data().get::<T>())
    }
}