Only close chans if they are open, closes #80
This commit is contained in:
parent
1da7bf090b
commit
61b3b8122c
1 changed files with 7 additions and 2 deletions
|
@ -125,8 +125,13 @@ func (s *Session) Close() {
|
|||
|
||||
s.DataReady = false
|
||||
|
||||
close(s.listenChan)
|
||||
close(s.heartbeatChan)
|
||||
if s.listenChan != nil {
|
||||
close(s.listenChan)
|
||||
}
|
||||
|
||||
if s.heartbeatChan != nil {
|
||||
close(s.heartbeatChan)
|
||||
}
|
||||
|
||||
if s.wsConn != nil {
|
||||
s.wsConn.Close()
|
||||
|
|
Loading…
Reference in a new issue