Skip to main content

keyed_counter_service

hydro_test::tutorials::keyed_counter

Function keyed_counter_service 

Source 
pub fn keyed_counter_service<'a, L: Location<'a> + NoTick>(
    increment_requests: KeyedStream<u32, String, L, Unbounded>,
    get_requests: KeyedStream<u32, String, L, Unbounded>,
) -> (KeyedStream<u32, String, L, Unbounded>, KeyedStream<u32, (String, usize), L, Unbounded, NoOrder>)