diff --git a/gix-packetline-blocking/src/encode/async_io.rs b/gix-packetline-blocking/src/encode/async_io.rs index 27566ada140..6532b84c9fa 100644 --- a/gix-packetline-blocking/src/encode/async_io.rs +++ b/gix-packetline-blocking/src/encode/async_io.rs @@ -3,7 +3,7 @@ use std::{ io, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::AsyncWrite; @@ -56,7 +56,6 @@ fn into_io_err(err: Error) -> io::Error { impl AsyncWrite for LineWriter<'_, W> { fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, data: &[u8]) -> Poll> { - use futures_lite::ready; let mut this = self.project(); loop { match &mut this.state { diff --git a/gix-packetline-blocking/src/read/sidebands/async_io.rs b/gix-packetline-blocking/src/read/sidebands/async_io.rs index 6ffe200590d..43224dd15fe 100644 --- a/gix-packetline-blocking/src/read/sidebands/async_io.rs +++ b/gix-packetline-blocking/src/read/sidebands/async_io.rs @@ -3,11 +3,10 @@ use std::{ future::Future, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::{AsyncBufRead, AsyncRead}; -use futures_lite::ready; use crate::{decode, read::ProgressAction, BandRef, PacketLineRef, StreamingPeekableIter, TextRef, U16_HEX_BYTES}; diff --git a/gix-packetline-blocking/src/write/async_io.rs b/gix-packetline-blocking/src/write/async_io.rs index a77dbe274a7..a5813e1ede8 100644 --- a/gix-packetline-blocking/src/write/async_io.rs +++ b/gix-packetline-blocking/src/write/async_io.rs @@ -3,7 +3,7 @@ use std::{ io, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::AsyncWrite; @@ -75,7 +75,7 @@ impl AsyncWrite for Writer { State::WriteData(written) => { while *written != buf.len() { let data = &buf[*written..*written + (buf.len() - *written).min(MAX_DATA_LEN)]; - let n = futures_lite::ready!(this.inner.as_mut().poll_write(cx, data))?; + let n = ready!(this.inner.as_mut().poll_write(cx, data))?; if n == 0 { return Poll::Ready(Err(io::ErrorKind::WriteZero.into())); } diff --git a/gix-packetline/src/encode/async_io.rs b/gix-packetline/src/encode/async_io.rs index 983644c1d9f..9add6f27a41 100644 --- a/gix-packetline/src/encode/async_io.rs +++ b/gix-packetline/src/encode/async_io.rs @@ -1,7 +1,7 @@ use std::{ io, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::AsyncWrite; @@ -54,7 +54,6 @@ fn into_io_err(err: Error) -> io::Error { impl AsyncWrite for LineWriter<'_, W> { fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, data: &[u8]) -> Poll> { - use futures_lite::ready; let mut this = self.project(); loop { match &mut this.state { diff --git a/gix-packetline/src/read/sidebands/async_io.rs b/gix-packetline/src/read/sidebands/async_io.rs index 1a04a381254..92e61114214 100644 --- a/gix-packetline/src/read/sidebands/async_io.rs +++ b/gix-packetline/src/read/sidebands/async_io.rs @@ -1,11 +1,10 @@ use std::{ future::Future, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::{AsyncBufRead, AsyncRead}; -use futures_lite::ready; use crate::{decode, read::ProgressAction, BandRef, PacketLineRef, StreamingPeekableIter, TextRef, U16_HEX_BYTES}; diff --git a/gix-packetline/src/write/async_io.rs b/gix-packetline/src/write/async_io.rs index 707d2b7b576..4775fc06df4 100644 --- a/gix-packetline/src/write/async_io.rs +++ b/gix-packetline/src/write/async_io.rs @@ -1,7 +1,7 @@ use std::{ io, pin::Pin, - task::{Context, Poll}, + task::{ready, Context, Poll}, }; use futures_io::AsyncWrite; @@ -73,7 +73,7 @@ impl AsyncWrite for Writer { State::WriteData(written) => { while *written != buf.len() { let data = &buf[*written..*written + (buf.len() - *written).min(MAX_DATA_LEN)]; - let n = futures_lite::ready!(this.inner.as_mut().poll_write(cx, data))?; + let n = ready!(this.inner.as_mut().poll_write(cx, data))?; if n == 0 { return Poll::Ready(Err(io::ErrorKind::WriteZero.into())); }