diff --git a/lib/parsers/warcStreamTransform.js b/lib/parsers/warcStreamTransform.js
index a6cbbb5..0aff85c 100644
--- a/lib/parsers/warcStreamTransform.js
+++ b/lib/parsers/warcStreamTransform.js
@@ -110,8 +110,9 @@ class WARCStreamTransform extends Transform {
   _flush (done) {
     if (this.buffered) {
       this._consumeChunk(this.buffered, done, true)
+    } else {
+      done()
     }
-    done()
   }
 }