package/delayqueue
1
0
Fork 0
mirror of https://github.com/HDT3213/delayqueue.git synced 2025-10-04 14:52:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix test suite

Browse Source
This commit is contained in:
finley
2023-08-20 17:41:48 +08:00
parent 076749c7cc
commit 8cabcf8c96
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
delayqueue_test.go
View File

@@ -164,7 +164,7 @@ func TestDelayQueue_StopConsume(t *testing.T) {
<-done <-done
} }
func TestDelayQueue_Massive_Consume(t *testing.T) { func TestDelayQueue_Massive_Backlog(t *testing.T) {
redisCli := redis.NewClient(&redis.Options{ redisCli := redis.NewClient(&redis.Options{
Addr: "127.0.0.1:6379", Addr: "127.0.0.1:6379",
}) })
@@ -195,7 +195,7 @@ func TestDelayQueue_Massive_Consume(t *testing.T) {
ids := make([]string, 0, q.fetchLimit) ids := make([]string, 0, q.fetchLimit)
for { for {
idStr, err := q.ready2Unack() idStr, err := q.ready2Unack()
if err == redis.Nil { // consumed all if err == NilErr { // consumed all
break break
} }
if err != nil { if err != nil {