Skip to content

Commit a86c201

Browse files
refactor: replace futures_lite::ready! with std::task::ready!
1 parent b5e9059 commit a86c201

File tree

6 files changed

+8
-12
lines changed

6 files changed

+8
-12
lines changed

gix-packetline-blocking/src/encode/async_io.rs

+1-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

gix-packetline-blocking/src/read/sidebands/async_io.rs

+1-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

gix-packetline-blocking/src/write/async_io.rs

+2-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

gix-packetline/src/encode/async_io.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use std::{
22
io,
33
pin::Pin,
4-
task::{Context, Poll},
4+
task::{ready, Context, Poll},
55
};
66

77
use futures_io::AsyncWrite;
@@ -54,7 +54,6 @@ fn into_io_err(err: Error) -> io::Error {
5454

5555
impl<W: AsyncWrite + Unpin> AsyncWrite for LineWriter<'_, W> {
5656
fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, data: &[u8]) -> Poll<io::Result<usize>> {
57-
use futures_lite::ready;
5857
let mut this = self.project();
5958
loop {
6059
match &mut this.state {

gix-packetline/src/read/sidebands/async_io.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,10 @@
11
use std::{
22
future::Future,
33
pin::Pin,
4-
task::{Context, Poll},
4+
task::{ready, Context, Poll},
55
};
66

77
use futures_io::{AsyncBufRead, AsyncRead};
8-
use futures_lite::ready;
98

109
use crate::{decode, read::ProgressAction, BandRef, PacketLineRef, StreamingPeekableIter, TextRef, U16_HEX_BYTES};
1110

gix-packetline/src/write/async_io.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use std::{
22
io,
33
pin::Pin,
4-
task::{Context, Poll},
4+
task::{ready, Context, Poll},
55
};
66

77
use futures_io::AsyncWrite;
@@ -73,7 +73,7 @@ impl<T: AsyncWrite + Unpin> AsyncWrite for Writer<T> {
7373
State::WriteData(written) => {
7474
while *written != buf.len() {
7575
let data = &buf[*written..*written + (buf.len() - *written).min(MAX_DATA_LEN)];
76-
let n = futures_lite::ready!(this.inner.as_mut().poll_write(cx, data))?;
76+
let n = ready!(this.inner.as_mut().poll_write(cx, data))?;
7777
if n == 0 {
7878
return Poll::Ready(Err(io::ErrorKind::WriteZero.into()));
7979
}

0 commit comments

Comments
 (0)