This commit is contained in:
Jeff Walter 2018-12-11 17:50:16 -06:00
commit 077668ca58

View File

@ -111,6 +111,8 @@ func (e *eventStream) listen() (connected chan bool) {
connected <- true connected <- true
} else if notifyResponse.Status == "disconnected" { } else if notifyResponse.Status == "disconnected" {
e.disconnect() e.disconnect()
} else if notifyResponse.Action == "logout" {
e.disconnect()
} else { } else {
e.subscriptions.rwmutex.RLock() e.subscriptions.rwmutex.RLock()
subscriber, ok := e.subscribers[notifyResponse.TransId] subscriber, ok := e.subscribers[notifyResponse.TransId]