Fixed goroutine leak

Signed-off-by: VladSaioc <vladsaioc10@gmail.com>
This commit is contained in:
VladSaioc 2022-07-31 22:18:01 +02:00
parent 046c46e52e
commit 3a775201c0

View File

@ -37,6 +37,9 @@ func TestQueueOneReaderOneWriter(t *testing.T) {
defer clus.Terminate(t)
done := make(chan struct{})
defer func() {
<-done
}()
go func() {
defer func() {
done <- struct{}{}
@ -61,7 +64,6 @@ func TestQueueOneReaderOneWriter(t *testing.T) {
t.Fatalf("expected dequeue value %v, got %v", s, i)
}
}
<-done
}
func TestQueueManyReaderOneWriter(t *testing.T) {