Skip to main content

create_subscriber

kaniop_operator::controller

Function create_subscriber 

Source 
pub fn create_subscriber<K>(buffer_size: usize) -> ResourceReflector<K>
where
    K: Resource + Lookup + Clone + 'static,
    <K as Lookup>::DynamicType: Default + Eq + Hash + Clone,
    <K as Resource>::DynamicType: Default + Eq + Hash + Clone,