Skip to content

Commit 3f44a7f

Browse files
committed
address copilot comments
1 parent 008ce11 commit 3f44a7f

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

internal/routing/aggregator.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -497,10 +497,6 @@ func (a *AggLogicalAndAggregator) Add(result interface{}, err error) error {
497497
if a.res.CompareAndSwap(old, desired) {
498498
break
499499
}
500-
// Early exit: if the value already equals what we want, no need to continue
501-
if a.res.Load() == desired {
502-
break
503-
}
504500
}
505501

506502
a.hasResult.Store(true)
@@ -596,10 +592,6 @@ func (a *AggLogicalOrAggregator) Add(result interface{}, err error) error {
596592
if a.res.CompareAndSwap(old, desired) {
597593
break
598594
}
599-
// Early exit: if the value already equals what we want, no need to continue
600-
if a.res.Load() == desired {
601-
break
602-
}
603595
}
604596

605597
a.hasResult.Store(true)

0 commit comments

Comments
 (0)