Function collect_at_least_n_bytes 

async fn collect_at_least_n_bytes(
    stream: &mut BoxStream<'static, Result<Bytes>>,
    n: usize,
    extend_from: Option<Vec<u8>>,
) -> Result<Vec<u8>>