fix foreach

zhangzengfei

2021-11-12 d7485b186f72742ee0a1bf34e7fc818b53f20870

 store_test.go

@@ -1,7 +1,6 @@
package boltcache

import (
   "strconv"
   "testing"
   "time"
)
@@ -18,19 +17,27 @@

   //go consume(ls)
   //
   for i := 0; i < 100; i++ {
      ls.ApplyLog([]byte("hello world " + strconv.Itoa(i)))
      time.Sleep(time.Millisecond * 100)
   }
   //for i := 0; i < 10; i++ {
   //   ls.ApplyLog([]byte("hello world " + strconv.Itoa(i)))
   //   time.Sleep(time.Millisecond * 100)
   //}

   ls.printLog("Size = ", ls.Size())

   ls.ForEach(func(v []byte) error {
      ls.printLog("val=:", string(v))
   var logs []*LogCon
   ls.ForEach(func(log *LogCon) error {
      ls.printLog("val=:", string(log.GetData()))

      logs = append(logs, log)
      time.Sleep(time.Millisecond * 100)

      return nil
   })

   consume(ls)
   for _, log := range logs {
      ls.Delete(log)
   }
   //consume(ls)
}

func consume(ls *LogStore) {