add comment to improve readability

absmach · Aug 12, 2022 · e3629a6 · e3629a6
1 parent c3e8065
commit e3629a6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/pkg/messaging/nats/pubsub.go b/pkg/messaging/nats/pubsub.go
@@ -84,6 +84,7 @@ func (ps *pubsub) Subscribe(id, topic string, handler messaging.MessageHandler)
 			}
 
 			ps.mu.Lock()
+			// value of s can changed while ps.mu is unlocked
 			s = ps.subscriptions[topic]
 		}
 	}

diff --git a/pkg/messaging/rabbitmq/pubsub.go b/pkg/messaging/rabbitmq/pubsub.go
@@ -85,6 +85,7 @@ func (ps *pubsub) Subscribe(id, topic string, handler messaging.MessageHandler)
 			}
 
 			ps.mu.Lock()
+			// value of s can changed while ps.mu is unlocked
 			s = ps.subscriptions[topic]
 		}
 	}