close connection more often

cart-packet-queue.go

@@ -26,8 +26,19 @@ func NewCartPacketQueue(connection net.Conn) *CartPacketQueue {
 	return queue
 }
 
-func (p *CartPacketQueue) HandleConnection(connection net.Conn) error {
+func (p *CartPacketQueue) RemoveListeners() {
+	p.mu.Lock()
+	defer p.mu.Unlock()
+	for _, l := range p.expectedPackages {
+		for _, l := range *l {
+			close(l.Chan)
+		}
+	}
+	p.expectedPackages = make(map[uint32]*CartListener)
+}
 
+func (p *CartPacketQueue) HandleConnection(connection net.Conn) error {
+	defer p.RemoveListeners()
 	defer connection.Close()
 	var packet CartPacket
 	reader := bufio.NewReader(connection)