Skip to content

Commit

Permalink
fix: ConsumeValues in aggreagation stage
Browse files Browse the repository at this point in the history
  • Loading branch information
adetunjii committed Sep 12, 2023
1 parent 3c786a7 commit 506f278
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions internal/handlers/common/aggregations/stages/group.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,6 @@ func newGroup(stage *types.Document) (aggregations.Stage, error) {

// Process implements Stage interface.
func (g *group) Process(ctx context.Context, iter types.DocumentsIterator, closer *iterator.MultiCloser) (types.DocumentsIterator, error) { //nolint:lll // for readability

groupedDocuments, err := g.groupDocuments(iter)
if err != nil {
return nil, err
Expand Down Expand Up @@ -231,7 +230,6 @@ func (g *group) groupDocuments(iter types.DocumentsIterator) ([]groupedDocuments
var m groupMap

for {

_, doc, err := iter.Next()
if errors.Is(err, iterator.ErrIteratorDone) {
break
Expand Down

0 comments on commit 506f278

Please sign in to comment.