fix test with closed flag

This commit is contained in:
Umputun
2018-11-12 03:23:45 -06:00
parent c60c8d3f15
commit 35f8b17ac3
+2 -1
View File
@@ -6,6 +6,7 @@ import (
"log"
"math/rand"
"sync"
"sync/atomic"
"testing"
"time"
@@ -84,7 +85,7 @@ func TestService_Nop(t *testing.T) {
s := NopService
s.Submit(store.Comment{})
s.Close()
assert.True(t, s.closed)
assert.Equal(t, uint32(1), atomic.LoadUint32(&s.closed))
}
type mockDest struct {