Function unique_id_server 

pub fn unique_id_server<'a, C: 'a>(
    input: KeyedStream<String, GenerateMessage, Cluster<'a, C>>,
    nondet_ids: NonDet,
) -> KeyedStream<String, Value, Cluster<'a, C>>