Skip to content

Commit

Permalink
fix bug in subscribed topic count
Browse files Browse the repository at this point in the history
  • Loading branch information
tsachiherman committed Feb 22, 2024
1 parent e0d9f57 commit f06531a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/api/message/v1/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ func (s *Service) Subscribe(req *proto.SubscribeRequest, stream proto.MessageApi
if sub != nil {
sub.Unsubscribe()
}
metrics.EmitUnsubscribeTopics(stream.Context(), log, 1)
metrics.EmitUnsubscribeTopics(stream.Context(), log, len(req.ContentTopics))
}()

var streamLock sync.Mutex
Expand Down

0 comments on commit f06531a

Please sign in to comment.