fix: forgot to close the queue (#25)

ramzeng · Aug 17, 2023 · 8e02cf8 · 8e02cf8
1 parent 1c442a0
commit 8e02cf8
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 8 deletions.
diff --git a/framedecoder.go b/framedecoder.go
@@ -91,7 +91,6 @@ type FrameDecoder struct {
 	discardingTooLongFrame bool
 	tooLongFrameLength     int64
 	bytesToDiscard         int64
-	frameLengthInt         int64
 	bytes                  []byte
 	lock                   sync.Mutex
 }

diff --git a/manager.go b/manager.go
@@ -34,13 +34,6 @@ func (cm *connectionManager) clearConnections() {
 	cm.connections = make(map[uint64]*Connection)
 }
 
-func (cm *connectionManager) connection(id uint64) *Connection {
-	cm.lock.RLock()
-	defer cm.lock.RUnlock()
-
-	return cm.connections[id]
-}
-
 func (cm *connectionManager) connectionsCount() int {
 	cm.lock.RLock()
 	defer cm.lock.RUnlock()

diff --git a/server.go b/server.go
@@ -99,6 +99,8 @@ func (s *Server) stop() <-chan struct{} {
 			debug("Server stopping...")
 
 			s.cancel()
+
+			s.queue.close()
 			s.connectionManager.clearConnections()
 
 			debug("Server stopped")