parent
78509b5f9b
commit
69b8d7ba19
|
@ -52,7 +52,7 @@ func TestPersistableChannelQueue(t *testing.T) {
|
||||||
err = queue.Push(&test1)
|
err = queue.Push(&test1)
|
||||||
assert.NoError(t, err)
|
assert.NoError(t, err)
|
||||||
go func() {
|
go func() {
|
||||||
err = queue.Push(&test2)
|
err := queue.Push(&test2)
|
||||||
assert.NoError(t, err)
|
assert.NoError(t, err)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|
|
@ -65,7 +65,7 @@ func TestLevelQueue(t *testing.T) {
|
||||||
err = queue.Push(&test1)
|
err = queue.Push(&test1)
|
||||||
assert.NoError(t, err)
|
assert.NoError(t, err)
|
||||||
go func() {
|
go func() {
|
||||||
err = queue.Push(&test2)
|
err := queue.Push(&test2)
|
||||||
assert.NoError(t, err)
|
assert.NoError(t, err)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue