Skip to main content

concurrent_counter_service

hydro_test::tutorials::concurrent_clients

Function concurrent_counter_service 

Source 
pub fn concurrent_counter_service<'a>(
    increment_requests: KeyedStream<u32, (), Process<'a, CounterServer>>,
    get_requests: KeyedStream<u32, (), Process<'a, CounterServer>>,
) -> (KeyedStream<u32, (), Process<'a, CounterServer>>, KeyedStream<u32, usize, Process<'a, CounterServer>>)