summaryrefslogtreecommitdiffstats
path: root/tokio-util/src/codec/framed_read.rs
diff options
context:
space:
mode:
authorTaiki Endo <te316e89@gmail.com>2019-11-17 02:14:40 +0900
committerCarl Lerche <me@carllerche.com>2019-11-16 09:14:40 -0800
commit320c84a433e5e54e386c17098fc6d36d15e4acff (patch)
tree47f9990adf3f76ff2b93231b241bb87d18fdaea1 /tokio-util/src/codec/framed_read.rs
parent19f1fc36bd567377bde4a2c6818c6b606d89d488 (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.rs28
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;