pub fn http_hello_server<'a, P>(
in_stream: KeyedStream<u64, String, Process<'a, P>, Unbounded, TotalOrder>,
) -> KeyedSingleton<u64, String, Process<'a, P>, BoundedValue>
pub fn http_hello_server<'a, P>(
in_stream: KeyedStream<u64, String, Process<'a, P>, Unbounded, TotalOrder>,
) -> KeyedSingleton<u64, String, Process<'a, P>, BoundedValue>