File tree Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Expand file tree Collapse file tree 1 file changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -82,10 +82,10 @@ func TestWorkerStatus(t *testing.T) {
82
82
assert .NoError (t , err )
83
83
assert .NotNil (t , q )
84
84
85
- q .Queue (m )
86
- q .Queue (m )
87
- q .Queue (m )
88
- q .Queue (m )
85
+ assert . NoError ( t , q .Queue (m ) )
86
+ assert . NoError ( t , q .Queue (m ) )
87
+ assert . NoError ( t , q .Queue (m ) )
88
+ assert . NoError ( t , q .Queue (m ) )
89
89
assert .Equal (t , 100 , q .Capacity ())
90
90
assert .Equal (t , 4 , q .Usage ())
91
91
q .Start ()
@@ -105,15 +105,15 @@ func TestWorkerPanic(t *testing.T) {
105
105
assert .NoError (t , err )
106
106
assert .NotNil (t , q )
107
107
108
- q .Queue (mockMessage {
108
+ assert . NoError ( t , q .Queue (mockMessage {
109
109
message : "foobar" ,
110
- })
111
- q .Queue (mockMessage {
110
+ }))
111
+ assert . NoError ( t , q .Queue (mockMessage {
112
112
message : "foobar" ,
113
- })
114
- q .Queue (mockMessage {
113
+ }))
114
+ assert . NoError ( t , q .Queue (mockMessage {
115
115
message : "panic" ,
116
- })
116
+ }))
117
117
q .Start ()
118
118
time .Sleep (30 * time .Millisecond )
119
119
assert .Equal (t , 2 , q .Workers ())
You can’t perform that action at this time.
0 commit comments