pub fn http_counter_server<'a, P>(
in_stream: KeyedStream<u64, String, Process<'a, P>, Unbounded, TotalOrder>,
process: &Process<'a, P>,
) -> 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>,
process: &Process<'a, P>,
) -> KeyedStream<u64, String, Process<'a, P>, Unbounded, NoOrder>