Function TestQuery_FindAll_Break

internal/utils/kvstore/query_test.go:41–70

(t *testing.T)

}

func TestQuery_FindAll_Break(t *testing.T) {
	var table = testOpenStoreTable[*testCachedItem](t, "cache_items", &testCacheItemEncoder[*testCachedItem]{})

	defer func() {
		_ = testingStore.Close()
	}()

	var before = time.Now()
	defer func() {
		t.Log("cost:", time.Since(before).Seconds()*1000, "ms")
	}()

	var count int
	err := table.
		Query().
		FindAll(func(tx *kvstore.Tx[*testCachedItem], item kvstore.Item[*testCachedItem]) (goNext bool, err error) {
			t.Log("key:", item.Key, "value:", item.Value)
			count++

			if count > 2 {
				// break test
				_ = table.DB().Store().Close()
			}

			return count < 3, nil
		})
	if err != nil {
		t.Log(err)
	}
}

func TestQuery_FindAll_Break_Closed(t *testing.T) {
	var table = testOpenStoreTable[*testCachedItem](t, "cache_items", &testCacheItemEncoder[*testCachedItem]{})