diff --git a/pkg/depth/buffer_test.go b/pkg/depth/buffer_test.go index fe8023641..8bb05cd56 100644 --- a/pkg/depth/buffer_test.go +++ b/pkg/depth/buffer_test.go @@ -64,7 +64,7 @@ func TestDepthBuffer_CorruptedUpdateAtTheBeginning(t *testing.T) { {Price: itov(99), Volume: itov(1)}, }, }, snapshotFinalID, nil - }) + }, time.Millisecond*5) resetC := make(chan struct{}, 1) @@ -104,7 +104,7 @@ func TestDepthBuffer_ConcurrentRun(t *testing.T) { {Price: itov(99), Volume: itov(1)}, }, }, snapshotFinalID, nil - }) + }, time.Millisecond*5) readyCnt := 0 resetCnt := 0