summaryrefslogtreecommitdiffstats
path: root/tokio-io
diff options
context:
space:
mode:
authorTaiki Endo <te316e89@gmail.com>2019-09-23 01:52:14 +0900
committerGitHub <noreply@github.com>2019-09-23 01:52:14 +0900
commit376d63867a850568991f01c742938612c0179e40 (patch)
tree99cfab31d084fa6452f7e7f3d5f7c76670fef7a9 /tokio-io
parenteb2d0fbcd122473932a1a7c97b16307facae5eb8 (diff)
chore: update pin-project to 0.4.0-beta.1 (#1586)
Diffstat (limited to 'tokio-io')
-rw-r--r--tokio-io/Cargo.toml4
-rw-r--r--tokio-io/src/io/buf_stream.rs12
2 files changed, 8 insertions, 8 deletions
diff --git a/tokio-io/Cargo.toml b/tokio-io/Cargo.toml
index 7290b672..65f119e4 100644
--- a/tokio-io/Cargo.toml
+++ b/tokio-io/Cargo.toml
@@ -20,7 +20,7 @@ Core I/O primitives for asynchronous I/O in Rust.
categories = ["asynchronous"]
[features]
-util = ["memchr", "pin-utils"]
+util = ["memchr", "pin-utils", "pin-project"]
[dependencies]
bytes = "0.4.7"
@@ -28,7 +28,7 @@ log = "0.4"
futures-core-preview = "=0.3.0-alpha.18"
memchr = { version = "2.2", optional = true }
pin-utils = { version = "=0.1.0-alpha.4", optional = true }
-pin-project = "=0.4.0-alpha.11"
+pin-project = { version = "=0.4.0-beta.1", optional = true }
[dev-dependencies]
tokio = { version = "=0.2.0-alpha.5", path = "../tokio" }
diff --git a/tokio-io/src/io/buf_stream.rs b/tokio-io/src/io/buf_stream.rs
index f2abfb08..88624f19 100644
--- a/tokio-io/src/io/buf_stream.rs
+++ b/tokio-io/src/io/buf_stream.rs
@@ -29,25 +29,25 @@ impl<RW: AsyncRead + AsyncWrite> BufStream<RW> {
impl<RW: AsyncRead + AsyncWrite> AsyncWrite for BufStream<RW> {
fn poll_write(
- mut self: Pin<&mut Self>,
+ self: Pin<&mut Self>,
cx: &mut Context<'_>,
buf: &[u8],
) -> Poll<io::Result<usize>> {
self.project().0.poll_write(cx, buf)
}
- fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
+ fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
self.project().0.poll_flush(cx)
}
- fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
+ fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
self.project().0.poll_shutdown(cx)
}
}
impl<RW: AsyncRead + AsyncWrite> AsyncRead for BufStream<RW> {
fn poll_read(
- mut self: Pin<&mut Self>,
+ self: Pin<&mut Self>,
cx: &mut Context<'_>,
buf: &mut [u8],
) -> Poll<io::Result<usize>> {
@@ -62,10 +62,10 @@ impl<RW: AsyncRead + AsyncWrite> AsyncRead for BufStream<RW> {
impl<RW: AsyncBufRead + AsyncRead + AsyncWrite> AsyncBufRead for BufStream<RW> {
fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> {
- self.project_into().0.poll_fill_buf(cx)
+ self.project().0.poll_fill_buf(cx)
}
- fn consume(mut self: Pin<&mut Self>, amt: usize) {
+ fn consume(self: Pin<&mut Self>, amt: usize) {
self.project().0.consume(amt)
}
}