appease linter
This commit is contained in:
parent
58cfac9f67
commit
6b3282150b
@ -440,7 +440,10 @@ func TestLoadLocal(t *testing.T) {
|
|||||||
}
|
}
|
||||||
msgs[cid] = struct{}{}
|
msgs[cid] = struct{}{}
|
||||||
}
|
}
|
||||||
mp.Close()
|
err = mp.Close()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
mp, err = New(tma, ds, "mptest")
|
mp, err = New(tma, ds, "mptest")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -629,7 +632,11 @@ func TestUpdates(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
mp.Close()
|
err = mp.Close()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
_, ok := <-ch
|
_, ok := <-ch
|
||||||
if ok {
|
if ok {
|
||||||
t.Fatal("expected closed channel, but got an update instead")
|
t.Fatal("expected closed channel, but got an update instead")
|
||||||
|
Loading…
Reference in New Issue
Block a user