Function process_stream 

pub fn process_stream<R, T, F>(input: R, processor: F) -> StreamIterator<R, T> 
where
    R: Read,
    F: Fn(&[u8]) -> Option<T> + 'static,