Sfoglia il codice sorgente

fix iter release when opening memory

Aneurin Barker Snook 11 mesi fa
parent
commit
b02681d7fd
1 ha cambiato i file con 6 aggiunte e 1 eliminazioni
  1. 6 1
      memory.go

+ 6 - 1
memory.go

@@ -69,10 +69,15 @@ func (c *MemoryCollection[T]) Open() error {
 		if err := c.c.Open(); err != nil {
 		if err := c.c.Open(); err != nil {
 			return err
 			return err
 		}
 		}
-		all, err := c.c.Iter().GetAll()
+
+		iter := c.c.Iter()
+		defer iter.Release()
+
+		all, err := iter.GetAll()
 		if err != nil {
 		if err != nil {
 			return err
 			return err
 		}
 		}
+
 		c.m = all
 		c.m = all
 	} else {
 	} else {
 		c.m = map[string]T{}
 		c.m = map[string]T{}