pub fn http_counter_server<'a, P>(
in_stream: KeyedStream<u64, String, Process<'a, P>, Unbounded, TotalOrder>,
) -> KeyedStream<u64, String, Process<'a, P>, Unbounded, NoOrder>pub fn http_counter_server<'a, P>(
in_stream: KeyedStream<u64, String, Process<'a, P>, Unbounded, TotalOrder>,
) -> KeyedStream<u64, String, Process<'a, P>, Unbounded, NoOrder>