X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/9bd91a76e6277f7716e206ddb665dc5fe6f5b583..d9fddc0f506eb4ead7049f5638674b2b8773fcaa:/replay_test.go diff --git a/replay_test.go b/replay_test.go index dfbe615..547b5e4 100644 --- a/replay_test.go +++ b/replay_test.go @@ -38,7 +38,7 @@ func TestReplaySyntheticLog(t *testing.T) { root := t.TempDir() clock := newTestClock() random := rand.New(rand.NewPCG(1, 2)) - memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer()) + memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog()) require.NoError(t, err) defer func() { @@ -71,7 +71,7 @@ func TestReplaySyntheticLog(t *testing.T) { memory = replayRequireRestart(t, memory, root, clock) require.Equal(t, messages, memory.log.Len()) - require.Greater(t, batches, 0) + require.Positive(t, batches) require.NoError(t, memory.Wait(t.Context())) t.Logf("%d messages, %d nodes, %d batches in %s", messages, memory.tree.Count(), batches, time.Since(start).Round(time.Second)) @@ -98,7 +98,7 @@ func replayRequireRestart(t *testing.T, memory *Memory, root string, clock *Test require.NoError(t, err) require.NoError(t, memory.Close()) - memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer()) + memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog()) require.NoError(t, err) require.NoError(t, memory.Wait(t.Context())) require.Equal(t, view, memory.View())