AsyncIterator _end race condition workaround

jacoscaz · Dec 27, 2020 · cf6f2ac · cf6f2ac
1 parent 6185bf7
commit cf6f2ac
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);
+          }
+        });
+      }
     }
   }