We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 5557da6 + 5cec537 commit 1ce4adaCopy full SHA for 1ce4ada
registry.go
@@ -50,6 +50,19 @@ func SendToTarget(m Messagable, sessionID SessionID) error {
50
return session.queueForSend(msg)
51
}
52
53
+//UnregisterSession removes a session from the set of known sessions
54
+func UnregisterSession(sessionID SessionID) error {
55
+ sessionsLock.Lock()
56
+ defer sessionsLock.Unlock()
57
+
58
+ if _, ok := sessions[sessionID]; ok {
59
+ delete(sessions, sessionID)
60
+ return nil
61
+ }
62
63
+ return errUnknownSession
64
+}
65
66
func registerSession(s *session) error {
67
sessionsLock.Lock()
68
defer sessionsLock.Unlock()
0 commit comments