mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-09-08 00:00:13 +02:00
io: fix take pointer check (#4437)
This commit is contained in:
@@ -84,11 +84,10 @@ impl<R: AsyncRead> AsyncRead for Take<R> {
|
|||||||
return Poll::Ready(Ok(()));
|
return Poll::Ready(Ok(()));
|
||||||
}
|
}
|
||||||
|
|
||||||
let buf_ptr = buf.filled().as_ptr();
|
|
||||||
|
|
||||||
let me = self.project();
|
let me = self.project();
|
||||||
let mut b = buf.take(*me.limit_ as usize);
|
let mut b = buf.take(*me.limit_ as usize);
|
||||||
|
|
||||||
|
let buf_ptr = b.filled().as_ptr();
|
||||||
ready!(me.inner.poll_read(cx, &mut b))?;
|
ready!(me.inner.poll_read(cx, &mut b))?;
|
||||||
assert_eq!(b.filled().as_ptr(), buf_ptr);
|
assert_eq!(b.filled().as_ptr(), buf_ptr);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user