Function distinct 

pub fn distinct<S, T>(stream: S) -> impl Stream<Item = T> + Send + 'static
where
    S: Stream<Item = T> + Send + 'static,
    T: Clone + Eq + Hash + Send + 'static,

Emit only the first occurrence of each item.