Function tap_diagnostics 

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

Returns a stream that runs f on each diagnostic packet, leaving it intact.

Non-diagnostic packets pass through without invoking f.