From 9cb694405c1ee0ae77e0683ce9896f75ba161979 Mon Sep 17 00:00:00 2001 From: Oleg Kovalov Date: Tue, 25 Jun 2024 15:21:57 +0200 Subject: [PATCH] test --- sync/sync_test.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/sync/sync_test.go b/sync/sync_test.go index 31124063..978d8d77 100644 --- a/sync/sync_test.go +++ b/sync/sync_test.go @@ -36,7 +36,7 @@ func TestSyncSimpleRequestingHead(t *testing.T) { require.NoError(t, err) require.Equal(t, exp.Height(), h101.Height()) - localStore := newTestStore(t, ctx, head) + localStore := newTestStore(t, ctx, head, store.WithWriteBatchSize(10)) syncer, err := NewSyncer( local.NewExchange(remoteStore), localStore, @@ -403,7 +403,9 @@ func (d *delayedGetter[H]) GetRangeByHeight(ctx context.Context, from H, to uint } // newTestStore creates initialized and started in memory header Store which is useful for testing. -func newTestStore(tb testing.TB, ctx context.Context, head *headertest.DummyHeader) header.Store[*headertest.DummyHeader] { +func newTestStore(tb testing.TB, ctx context.Context, head *headertest.DummyHeader, + opts ...store.Option, +) header.Store[*headertest.DummyHeader] { ds := sync.MutexWrap(datastore.NewMapDatastore()) - return store.NewTestStore(tb, ctx, ds, head) + return store.NewTestStore(tb, ctx, ds, head, opts...) }