diff --git a/generic/threadshare/src/runtime/executor/async_wrapper.rs b/generic/threadshare/src/runtime/executor/async_wrapper.rs index 434533aa..7da22001 100644 --- a/generic/threadshare/src/runtime/executor/async_wrapper.rs +++ b/generic/threadshare/src/runtime/executor/async_wrapper.rs @@ -399,7 +399,7 @@ impl AsyncRead for Async { buf: &mut [u8], ) -> Poll> { 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 AsyncRead for Async { bufs: &mut [IoSliceMut<'_>], ) -> Poll> { 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 AsyncWrite for Async { buf: &[u8], ) -> Poll> { 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 AsyncWrite for Async { bufs: &[IoSlice<'_>], ) -> Poll> { 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 AsyncWrite for Async { fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll> { 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), }