pub fn read_while_map<F, T>( interface: &Interface, buf_size: usize, buffers: usize, map: F, ) -> Result<impl Stream<Item = T>, Error>where F: FnMut(&[u8]) -> Option<T>,