Skip to content

Commit 273dd44

Browse files
committed
fix(io): use pin-project-lite
1 parent a074a57 commit 273dd44

File tree

2 files changed

+12
-11
lines changed

2 files changed

+12
-11
lines changed

compio-io/Cargo.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ repository = { workspace = true }
1414
compio-buf = { workspace = true, features = ["arrayvec"] }
1515
futures-util = { workspace = true }
1616
paste = { workspace = true }
17-
pin-project = { version = "1.1.3", optional = true }
17+
pin-project-lite = { version = "0.2.14", optional = true }
1818

1919
[dev-dependencies]
2020
compio-runtime = { workspace = true }
@@ -23,7 +23,7 @@ tokio = { workspace = true, features = ["macros", "rt"] }
2323

2424
[features]
2525
default = []
26-
compat = ["futures-util/io", "dep:pin-project"]
26+
compat = ["futures-util/io", "dep:pin-project-lite"]
2727

2828
# Nightly features
2929
allocator_api = ["compio-buf/allocator_api"]

compio-io/src/compat.rs

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ use std::{
88
};
99

1010
use compio_buf::{BufResult, IntoInner, IoBuf, IoBufMut, SetBufInit};
11-
use pin_project::pin_project;
11+
use pin_project_lite::pin_project;
1212

1313
use crate::{buffer::Buffer, util::DEFAULT_BUF_SIZE};
1414

@@ -167,14 +167,15 @@ impl<S: crate::AsyncWrite> SyncStream<S> {
167167

168168
type PinBoxFuture<T> = Pin<Box<dyn Future<Output = T>>>;
169169

170-
/// A stream wrapper for [`futures_util::io`] traits.
171-
#[pin_project]
172-
pub struct AsyncStream<S> {
173-
#[pin]
174-
inner: SyncStream<S>,
175-
read_future: Option<PinBoxFuture<io::Result<usize>>>,
176-
write_future: Option<PinBoxFuture<io::Result<usize>>>,
177-
shutdown_future: Option<PinBoxFuture<io::Result<()>>>,
170+
pin_project! {
171+
/// A stream wrapper for [`futures_util::io`] traits.
172+
pub struct AsyncStream<S> {
173+
#[pin]
174+
inner: SyncStream<S>,
175+
read_future: Option<PinBoxFuture<io::Result<usize>>>,
176+
write_future: Option<PinBoxFuture<io::Result<usize>>>,
177+
shutdown_future: Option<PinBoxFuture<io::Result<()>>>,
178+
}
178179
}
179180

180181
impl<S> AsyncStream<S> {

0 commit comments

Comments
 (0)