Skip to content

Commit

Permalink
fix typo in comment
Browse files Browse the repository at this point in the history
Signed-off-by: aryan <aryangodara03@gmail.com>
  • Loading branch information
AryanGodara committed Aug 12, 2022
1 parent d484937 commit ff6c6ba
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion pkg/messaging/nats/pubsub.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +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
// value of s can be changed while ps.mu is unlocked
s = ps.subscriptions[topic]
}
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/messaging/rabbitmq/pubsub.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +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
// value of s can be changed while ps.mu is unlocked
s = ps.subscriptions[topic]
}
}
Expand Down

0 comments on commit ff6c6ba

Please sign in to comment.