summaryrefslogtreecommitdiffstats
path: root/tokio-io/src/_tokio_codec/framed_read.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tokio-io/src/_tokio_codec/framed_read.rs')
-rw-r--r--tokio-io/src/_tokio_codec/framed_read.rs13
1 files changed, 6 insertions, 7 deletions
diff --git a/tokio-io/src/_tokio_codec/framed_read.rs b/tokio-io/src/_tokio_codec/framed_read.rs
index ea755087..a1285170 100644
--- a/tokio-io/src/_tokio_codec/framed_read.rs
+++ b/tokio-io/src/_tokio_codec/framed_read.rs
@@ -1,13 +1,12 @@
#![allow(deprecated)]
-use std::fmt;
-
use super::framed::Fuse;
-use codec::Decoder;
-use AsyncRead;
-
+use crate::codec::Decoder;
+use crate::AsyncRead;
use bytes::BytesMut;
-use futures::{Async, Poll, Sink, StartSend, Stream};
+use futures::{try_ready, Async, Poll, Sink, StartSend, Stream};
+use log::trace;
+use std::fmt;
/// A `Stream` of messages decoded from an `AsyncRead`.
pub struct FramedRead<T, D> {
@@ -117,7 +116,7 @@ where
T: fmt::Debug,
D: fmt::Debug,
{
- fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
+ fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
f.debug_struct("FramedRead")
.field("inner", &self.inner.inner.0)
.field("decoder", &self.inner.inner.1)