Fix set hub to closed before closing sessions
This commit is contained in:
@@ -99,13 +99,14 @@ loop:
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
case m := <-h.exit:
|
case m := <-h.exit:
|
||||||
|
h.open.Store(false)
|
||||||
|
|
||||||
h.sessions.each(func(s *Session) {
|
h.sessions.each(func(s *Session) {
|
||||||
s.writeMessage(m)
|
s.writeMessage(m)
|
||||||
s.Close()
|
s.Close()
|
||||||
})
|
})
|
||||||
|
|
||||||
h.sessions.clear()
|
h.sessions.clear()
|
||||||
h.open.Store(false)
|
|
||||||
|
|
||||||
break loop
|
break loop
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user