Method poll_next

src/io/streams.rs:152–164

(self: Pin<&mut Self>, cx: &mut Context<'_>)

impl futures_lite::stream::Stream for AsyncInputChunkStream {
    type Item = Result<Vec<u8>, std::io::Error>;
    fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
        match self.stream.poll_ready(cx) {
            Poll::Pending => Poll::Pending,
            Poll::Ready(()) => match self.stream.stream.read(self.chunk_size as u64) {
                Ok(r) if r.is_empty() => Poll::Pending,
                Ok(r) => Poll::Ready(Some(Ok(r))),
                Err(StreamError::LastOperationFailed(err)) => {
                    Poll::Ready(Some(Err(std::io::Error::other(err.to_debug_string()))))
                }
                Err(StreamError::Closed) => Poll::Ready(None),
            },
        }
    }
}

pin_project_lite::pin_project! {