add comments to improve readability

Signed-off-by: aryan <aryangodara03@gmail.com>
absmach · Aug 12, 2022 · d484937 · d484937
1 parent c3e8065
commit d484937
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 the ps mutex 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 the ps mutex is unlocked
 			s = ps.subscriptions[topic]
 		}
 	}