}
func TestAFailedSyncFailsEachLaterFlush(t *testing.T) {
+ failure := errors.New("disk error")
s := newSyncer(func() error {
- return errors.New("disk error")
+ return failure
})
s.Written()
- require.ErrorContains(t, s.Flush(t.Context()), "disk error")
+ require.ErrorIs(t, s.Flush(t.Context()), failure)
s.Written()
- require.ErrorContains(t, s.Flush(t.Context()), "disk error")
- require.ErrorContains(t, s.Close(), "disk error")
+ require.ErrorIs(t, s.Flush(t.Context()), failure)
+ require.ErrorIs(t, s.Close(), failure)
}
func TestMemoryFlushSyncsTheChat(t *testing.T) {