fix linter

bolt_transport.go

@@ -257,16 +257,7 @@ func (t *BoltTransport) dispatchHistory(s *Subscriber, toSeq uint64) {
 				return fmt.Errorf("unable to unmarshal update: %w", err)
 			}
 
-			var disconnected bool
-			for _, t := range update.Topics {
-				if s.Match(t, update.Private) {
-					disconnected = !s.Dispatch(update, true)
-
-					break
-				}
-			}
-
-			if disconnected || (toSeq > 0 && binary.BigEndian.Uint64(k[:8]) >= toSeq) {
+			if (s.Match(update) && !s.Dispatch(update, true)) || (toSeq > 0 && binary.BigEndian.Uint64(k[:8]) >= toSeq) {
 				s.HistoryDispatched(responseLastEventID)
 
 				return nil

subscriber.go

@@ -152,8 +152,8 @@ func escapeTopics(topics []string) []string {
 	return escapedTopics
 }
 
-// Match checks if the current subscriber can access to the given topic.
-func (s *Subscriber) Match(topic string, private bool) (match bool) {
+// MatchTopic checks if the current subscriber can access to the given topic.
+func (s *Subscriber) MatchTopic(topic string, private bool) (match bool) {
 	for i, ts := range s.Topics {
 		if ts == "*" || ts == topic {
 			match = true
@@ -190,11 +190,22 @@ func (s *Subscriber) Match(topic string, private bool) (match bool) {
 	return false
 }
 
+// Match checks if the current subscriber can receive the given update.
+func (s *Subscriber) Match(u *Update) bool {
+	for _, t := range u.Topics {
+		if s.MatchTopic(t, u.Private) {
+			return true
+		}
+	}
+
+	return false
+}
+
 // getSubscriptions return the list of subscriptions associated to this subscriber.
 func (s *Subscriber) getSubscriptions(topic, context string, active bool) []subscription {
 	var subscriptions []subscription //nolint:prealloc
 	for k, t := range s.Topics {
-		if topic != "" && !s.Match(topic, false) {
+		if topic != "" && !s.MatchTopic(topic, false) {
 			continue
 		}
 

subscriber_list.go

@@ -18,7 +18,7 @@ func NewSubscriberList(size int) *SubscriberList {
 				return false
 			}
 
-			return s.(*Subscriber).Match(p[1], p[0] == "p")
+			return s.(*Subscriber).MatchTopic(p[1], p[0] == "p")
 		}, size),
 	}
 }