diff options
author | Taiki Endo <te316e89@gmail.com> | 2019-11-17 02:14:40 +0900 |
---|---|---|
committer | Carl Lerche <me@carllerche.com> | 2019-11-16 09:14:40 -0800 |
commit | 320c84a433e5e54e386c17098fc6d36d15e4acff (patch) | |
tree | 47f9990adf3f76ff2b93231b241bb87d18fdaea1 /tokio-util/src/codec/framed_read.rs | |
parent | 19f1fc36bd567377bde4a2c6818c6b606d89d488 (diff) |
chore: migrate from pin-project to pin-project-lite (#1778)
Diffstat (limited to 'tokio-util/src/codec/framed_read.rs')
-rw-r--r-- | tokio-util/src/codec/framed_read.rs | 28 |
1 files changed, 15 insertions, 13 deletions
diff --git a/tokio-util/src/codec/framed_read.rs b/tokio-util/src/codec/framed_read.rs index 9e8beb03..bd1f625b 100644 --- a/tokio-util/src/codec/framed_read.rs +++ b/tokio-util/src/codec/framed_read.rs @@ -7,25 +7,27 @@ use bytes::BytesMut; use futures_core::Stream; use futures_sink::Sink; use log::trace; -use pin_project::pin_project; +use pin_project_lite::pin_project; use std::fmt; use std::pin::Pin; use std::task::{Context, Poll}; -/// A `Stream` of messages decoded from an `AsyncRead`. -#[pin_project] -pub struct FramedRead<T, D> { - #[pin] - inner: FramedRead2<Fuse<T, D>>, +pin_project! { + /// A `Stream` of messages decoded from an `AsyncRead`. + pub struct FramedRead<T, D> { + #[pin] + inner: FramedRead2<Fuse<T, D>>, + } } -#[pin_project] -pub(crate) struct FramedRead2<T> { - #[pin] - inner: T, - eof: bool, - is_readable: bool, - buffer: BytesMut, +pin_project! { + pub(crate) struct FramedRead2<T> { + #[pin] + inner: T, + eof: bool, + is_readable: bool, + buffer: BytesMut, + } } const INITIAL_CAPACITY: usize = 8 * 1024; |