Function poll_read_helper

fn poll_read_helper<S>(
    s: Pin<&mut ByteReader<S>>,
    cx: &mut Context<'_>,
    buf_len: usize,
) -> Poll<Result<Option<Bytes>>>
where
    S: Stream<Item = Result<Message, Error>> + Unpin,