From f63cf139411b4e8f10254a287c8a26064e3de187 Mon Sep 17 00:00:00 2001 From: finley Date: Fri, 16 Feb 2024 19:53:18 +0800 Subject: [PATCH] revert test suite --- delayqueue_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/delayqueue_test.go b/delayqueue_test.go index cd41acd..4959e07 100644 --- a/delayqueue_test.go +++ b/delayqueue_test.go @@ -36,7 +36,7 @@ func TestDelayQueue_consume(t *testing.T) { t.Error(err) } } - for i := 0; i < 10; i++ { + for i := 0; i < 10*size; i++ { err := queue.consume() if err != nil { t.Errorf("consume error: %v", err) @@ -85,7 +85,7 @@ func TestDelayQueueOnCluster(t *testing.T) { t.Error(err) } } - for i := 0; i < size; i++ { + for i := 0; i < 10*size; i++ { err := queue.consume() if err != nil { t.Errorf("consume error: %v", err)