Fix bug that a resource leak

hexojs · May 11, 2020 · c8af95d · c8af95d
1 parent 742d62c
commit c8af95d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/database.js b/lib/database.js
@@ -134,7 +134,10 @@ class Database {
     const rs = fs.createReadStream(path, 'utf8');
 
     const promise = new Promise((resolve, reject) => {
-      parseStream.once('error', reject);
+      parseStream.once('error', err => {
+        rs.destroy(err);
+        reject(err);
+      });
       parseStream.once('end', resolve);
 
       rs.once('error', reject);