Merge pull request #125 from m-ld/master

Fix for a race condition around duplicate calls to the _end method of the AsyncIterator wrapper around LevelIterator
jacoscaz · Dec 29, 2020 · 2f2d555 · 2f2d555
2 parents 6185bf7 + cf6f2ac
commit 2f2d555
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/lib/get/leveliterator.ts b/lib/get/leveliterator.ts
@@ -56,13 +56,15 @@ export class LevelIterator extends BufferedIterator<Quad> {
 
 
   protected _end(destroy?: boolean) {
-    super._end(destroy);
-    if (!destroy) {
-      this.level.end((endErr?: Error) => {
-        if (endErr) {
-          this.emit('error', endErr);
-        }
-      });
+    if (!this.ended) {
+      super._end(destroy);
+      if (!destroy) {
+        this.level.end((endErr?: Error) => {
+          if (endErr) {
+            this.emit('error', endErr);
+          }
+        });
+      }
     }
   }