Function reader_ref_with_capacity 

pub fn reader_ref_with_capacity<'a, R: AsyncRead + Unpin + Send>(
    reader: &'a mut R,
    capacity: usize,
) -> Pin<Box<dyn Stream<Item = Result<Vec<u8>, Error>> + Send + 'a>>