cleanup

Nullus157 · Oct 8, 2024 · df982ea · df982ea
1 parent 6b23477
commit df982ea
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/src/tokio/bufread/generic/decoder.rs b/src/tokio/bufread/generic/decoder.rs
@@ -95,10 +95,7 @@ impl<R: AsyncBufRead, D: Decode> Decoder<R, D> {
                             let done = this.decoder.decode(&mut input, output)?;
                             let len = input.written().len();
                             this.reader.as_mut().consume(len);
-                            if output.written().is_empty() {
-                                *this.multiple_members = false;
-                                State::Flushing
-                            } else if done {
+                            if done {
                                 State::Flushing
                             } else {
                                 State::Decoding