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>,