From 1837e7c86ca15b541b8a5ce9683ba3baa08c674b Mon Sep 17 00:00:00 2001 From: Alexey Khit Date: Mon, 17 Apr 2023 10:08:42 +0300 Subject: [PATCH] Fix cons number in trace logs --- cmd/streams/stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/streams/stream.go b/cmd/streams/stream.go index 2300b53e..8c7be19d 100644 --- a/cmd/streams/stream.go +++ b/cmd/streams/stream.go @@ -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