diff options
-rw-r--r-- | generic/threadshare/src/runtime/executor/async_wrapper.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/generic/threadshare/src/runtime/executor/async_wrapper.rs b/generic/threadshare/src/runtime/executor/async_wrapper.rs index 434533aa6..7da220010 100644 --- a/generic/threadshare/src/runtime/executor/async_wrapper.rs +++ b/generic/threadshare/src/runtime/executor/async_wrapper.rs @@ -399,7 +399,7 @@ impl<T: Read + Send + 'static> AsyncRead for Async<T> { buf: &mut [u8], ) -> Poll<io::Result<usize>> { loop { - match (&mut *self).get_mut().read(buf) { + match (*self).get_mut().read(buf) { Err(err) if err.kind() == io::ErrorKind::WouldBlock => {} res => return Poll::Ready(res), } @@ -413,7 +413,7 @@ impl<T: Read + Send + 'static> AsyncRead for Async<T> { bufs: &mut [IoSliceMut<'_>], ) -> Poll<io::Result<usize>> { loop { - match (&mut *self).get_mut().read_vectored(bufs) { + match (*self).get_mut().read_vectored(bufs) { Err(err) if err.kind() == io::ErrorKind::WouldBlock => {} res => return Poll::Ready(res), } @@ -462,7 +462,7 @@ impl<T: Write + Send + 'static> AsyncWrite for Async<T> { buf: &[u8], ) -> Poll<io::Result<usize>> { loop { - match (&mut *self).get_mut().write(buf) { + match (*self).get_mut().write(buf) { Err(err) if err.kind() == io::ErrorKind::WouldBlock => {} res => return Poll::Ready(res), } @@ -476,7 +476,7 @@ impl<T: Write + Send + 'static> AsyncWrite for Async<T> { bufs: &[IoSlice<'_>], ) -> Poll<io::Result<usize>> { loop { - match (&mut *self).get_mut().write_vectored(bufs) { + match (*self).get_mut().write_vectored(bufs) { Err(err) if err.kind() == io::ErrorKind::WouldBlock => {} res => return Poll::Ready(res), } @@ -486,7 +486,7 @@ impl<T: Write + Send + 'static> AsyncWrite for Async<T> { fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { loop { - match (&mut *self).get_mut().flush() { + match (*self).get_mut().flush() { Err(err) if err.kind() == io::ErrorKind::WouldBlock => {} res => return Poll::Ready(res), } |