diff --git a/src/tokio/bufread/generic/decoder.rs b/src/tokio/bufread/generic/decoder.rs
index b3ab043..c4fdb98 100644
--- a/src/tokio/bufread/generic/decoder.rs
+++ b/src/tokio/bufread/generic/decoder.rs
@@ -98,10 +98,12 @@ impl<R: AsyncBufRead, D: Decode> Decoder<R, D> {
                             }
                         });
 
-                        first = false;
+                        if !first {
+                            let len = input.written().len();
+                            this.reader.as_mut().consume(len);
+                        }
 
-                        let len = input.written().len();
-                        this.reader.as_mut().consume(len);
+                        first = false;
 
                         if res? {
                             State::Flushing