diff options
author | Taiki Endo <te316e89@gmail.com> | 2019-09-23 01:52:14 +0900 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-09-23 01:52:14 +0900 |
commit | 376d63867a850568991f01c742938612c0179e40 (patch) | |
tree | 99cfab31d084fa6452f7e7f3d5f7c76670fef7a9 /tokio-io | |
parent | eb2d0fbcd122473932a1a7c97b16307facae5eb8 (diff) |
chore: update pin-project to 0.4.0-beta.1 (#1586)
Diffstat (limited to 'tokio-io')
-rw-r--r-- | tokio-io/Cargo.toml | 4 | ||||
-rw-r--r-- | tokio-io/src/io/buf_stream.rs | 12 |
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) } } |