Skip to content

Commit b4680e5

Browse files
committed
test: fix check default Queue size
1 parent 504d4e0 commit b4680e5

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

simple/simple_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package simple
22

33
import (
4-
"runtime"
54
"testing"
65
"time"
76

@@ -20,7 +19,7 @@ func (m mockMessage) Bytes() []byte {
2019

2120
func TestQueueUsage(t *testing.T) {
2221
w := NewWorker()
23-
assert.Equal(t, runtime.NumCPU()<<1, w.Capacity())
22+
assert.Equal(t, defaultQueueSize, w.Capacity())
2423
assert.Equal(t, 0, w.Usage())
2524

2625
assert.NoError(t, w.Queue(&mockMessage{}))

0 commit comments

Comments
 (0)