Function map 

pub fn map<F>(source: Stream, f: F) -> Stream
where
    F: Fn(StreamItem) -> Result<StreamItem> + Send + Sync + 'static,

Returns a stream that applies f to every packet of source.