Skip to main content

keyed_counter_service_buggy

hydro_test::tutorials::keyed_counter_non_atomic

Function keyed_counter_service_buggy 

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