Function reader_with_capacity 

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