aboutsummaryrefslogtreecommitdiff
path: root/src/io/util/buf_stream.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/io/util/buf_stream.rs')
-rw-r--r--src/io/util/buf_stream.rs12
1 files changed, 3 insertions, 9 deletions
diff --git a/src/io/util/buf_stream.rs b/src/io/util/buf_stream.rs
index a56a451..cc857e2 100644
--- a/src/io/util/buf_stream.rs
+++ b/src/io/util/buf_stream.rs
@@ -1,9 +1,8 @@
use crate::io::util::{BufReader, BufWriter};
-use crate::io::{AsyncBufRead, AsyncRead, AsyncWrite};
+use crate::io::{AsyncBufRead, AsyncRead, AsyncWrite, ReadBuf};
use pin_project_lite::pin_project;
use std::io;
-use std::mem::MaybeUninit;
use std::pin::Pin;
use std::task::{Context, Poll};
@@ -137,15 +136,10 @@ impl<RW: AsyncRead + AsyncWrite> AsyncRead for BufStream<RW> {
fn poll_read(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
- buf: &mut [u8],
- ) -> Poll<io::Result<usize>> {
+ buf: &mut ReadBuf<'_>,
+ ) -> Poll<io::Result<()>> {
self.project().inner.poll_read(cx, buf)
}
-
- // we can't skip unconditionally because of the large buffer case in read.
- unsafe fn prepare_uninitialized_buffer(&self, buf: &mut [MaybeUninit<u8>]) -> bool {
- self.inner.prepare_uninitialized_buffer(buf)
- }
}
impl<RW: AsyncRead + AsyncWrite> AsyncBufRead for BufStream<RW> {