Function tap 

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

Returns a stream that runs f on each packet as a side effect, unchanged.