Fix cons number in trace logs

2023-04-17 10:08:42 +03:00
parent 235f2fde0d
commit 1837e7c86c
1 changed files with 1 additions and 1 deletions
@@ -48,7 +48,7 @@ func (s *Stream) SetSource(source string) {

 func (s *Stream) AddConsumer(cons core.Consumer) (err error) {
 	// support for multiple simultaneous requests from different consumers
-	consN := atomic.AddInt32(&s.requests, 1)
+	consN := atomic.AddInt32(&s.requests, 1) - 1

 	var producers []*Producer // matched producers for consumer