Close an existing iterator if it exists

islamaliev · Aug 22, 2024 · d37b6e4 · d37b6e4
1 parent d2e6590
commit d37b6e4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/db/fetcher/indexer_iterators.go b/internal/db/fetcher/indexer_iterators.go
@@ -81,6 +81,11 @@ var _ indexIterator = (*indexPrefixIterator)(nil)
 func (iter *indexPrefixIterator) Init(ctx context.Context, store datastore.DSReaderWriter) error {
 	iter.ctx = ctx
 	iter.store = store
+	if iter.resultIter != nil {
+		if err := iter.resultIter.Close(); err != nil {
+			return err
+		}
+	}
 	iter.resultIter = nil
 	return nil
 }