diff --git a/pkg/services/policer/policer_test.go b/pkg/services/policer/policer_test.go index 41abeb38..50f206fd 100644 --- a/pkg/services/policer/policer_test.go +++ b/pkg/services/policer/policer_test.go @@ -48,16 +48,12 @@ func TestBuryObjectWithoutContainer(t *testing.T) { return nil } - // Task pool - pool, err := ants.NewPool(4) - require.NoError(t, err) - // Policer instance p := New( WithKeySpaceIterator(&sliceKeySpaceIterator{objs: objs}), WithContainerSource(containerSrc), WithBuryFunc(buryFn), - WithPool(pool), + WithPool(testPool(t)), ) ctx, cancel := context.WithCancel(context.Background()) @@ -298,9 +294,6 @@ func TestIteratorContract(t *testing.T) { return nil } - pool, err := ants.NewPool(4) - require.NoError(t, err) - it := &predefinedIterator{ scenario: []nextResult{ {objs, nil}, @@ -326,7 +319,7 @@ func TestIteratorContract(t *testing.T) { WithKeySpaceIterator(it), WithContainerSource(containerSrc), WithBuryFunc(buryFn), - WithPool(pool), + WithPool(testPool(t)), func(c *cfg) { c.sleepDuration = time.Millisecond },