diff --git a/broker/client.go b/broker/client.go index 990b62f..f479489 100644 --- a/broker/client.go +++ b/broker/client.go @@ -364,6 +364,8 @@ func (c *client) ProcessUnSubscribe(packet *packets.UnsubscribePacket) { if ok && len(c.rsubs[t]) > 0 { sub = c.rsubs[t][0] c.rsubs[t] = c.rsubs[t][1:] + } else { + return } } if ok {