Add poll_read_exact impls to tokio-util

Author: a1phyr

tokio-util/src/either.rs

@@ -104,6 +104,14 @@ where
     ) -> Poll<Result<()>> {
         delegate_call!(self.poll_read(cx, buf))
     }
+
+    fn poll_read_exact(
+        self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+        buf: &mut ReadBuf<'_>,
+    ) -> Poll<std::io::Result<()>> {
+        delegate_call!(self.poll_read_exact(cx, buf))
+    }
 }
 
 impl<L, R> AsyncBufRead for Either<L, R>

tokio-util/src/io/inspect.rs

@@ -176,4 +176,12 @@ impl<W: AsyncRead, F> AsyncRead for InspectWriter<W, F> {
     ) -> Poll<std::io::Result<()>> {
         self.project().writer.poll_read(cx, buf)
     }
+
+    fn poll_read_exact(
+        self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+        buf: &mut ReadBuf<'_>,
+    ) -> Poll<std::io::Result<()>> {
+        self.project().writer.poll_read_exact(cx, buf)
+    }
 }

tokio-util/src/io/sink_writer.rs

@@ -131,4 +131,12 @@ impl<S: AsyncRead> AsyncRead for SinkWriter<S> {
     ) -> Poll<io::Result<()>> {
         self.project().inner.poll_read(cx, buf)
     }
+
+    fn poll_read_exact(
+        self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+        buf: &mut tokio::io::ReadBuf<'_>,
+    ) -> Poll<io::Result<()>> {
+        self.project().inner.poll_read_exact(cx, buf)
+    }
 }