diff --git a/lib/get/leveliterator.ts b/lib/get/leveliterator.ts index 0a19c16..c71ec82 100644 --- a/lib/get/leveliterator.ts +++ b/lib/get/leveliterator.ts @@ -56,13 +56,15 @@ export class LevelIterator extends BufferedIterator { 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); + } + }); + } } }