Merge pull request redpanda-data#906 from nibbleshift/optimize-proces…

…s-message call wg.Done() directly instead of deferring
chunchun010 · Oct 20, 2021 · 6c0e64e · 6c0e64e
2 parents 68801ab + d11d96b
commit 6c0e64e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/pipeline/processor.go b/lib/pipeline/processor.go
@@ -149,8 +149,8 @@ func (p *Processor) dispatchMessages(msgs []types.Message, ogResChan chan<- type
 
  for _, msg := range msgs {
  go func(m types.Message) {
- defer wg.Done()
  sendMsg(m)
+ wg.Done()
  }(msg)
  }