diff --git a/index.js b/index.js
index f369a29..29c149b 100644
--- a/index.js
+++ b/index.js
@@ -38,9 +38,8 @@ export default class FileType extends Transform {
 
   _flush (cb) {
     if (this[kStream] != null) {
-      this[kStream].end(() => cb(null))
-    } else {
-      cb(null)
+      this[kStream].end()
     }
+    cb(null)
   }
 }