From c778c5b202bf9c93a7ec03560a008c9d44fb9a92 Mon Sep 17 00:00:00 2001
From: gammazero <11790789+gammazero@users.noreply.github.com>
Date: Tue, 18 Feb 2025 21:33:26 -1000
Subject: [PATCH] query result ordering does not create additional goroutine

Previously, query ordering collected and sorted query results and then used a goprocess goroutine to send those results over a channel. This change eliminates the goroutine and uses a query Iiterator to directly return the sorted results.
---
 query/query_impl.go | 49 ++++++++++++++++++++-------------------------
 1 file changed, 22 insertions(+), 27 deletions(-)

diff --git a/query/query_impl.go b/query/query_impl.go
index dd554e74..4a4e79eb 100644
--- a/query/query_impl.go
+++ b/query/query_impl.go
@@ -2,8 +2,6 @@ package query
 
 import (
 	"path"
-
-	goprocess "github.com/jbenet/goprocess"
 )
 
 // NaiveFilter applies a filter to the results.
@@ -84,35 +82,32 @@ func NaiveOrder(qr Results, orders ...Order) Results {
 		return qr
 	}
 
-	return ResultsWithProcess(qr.Query(), func(worker goprocess.Process, out chan<- Result) {
-		defer qr.Close()
-		var entries []Entry
-	collect:
-		for {
-			select {
-			case <-worker.Closing():
-				return
-			case e, ok := <-qr.Next():
-				if !ok {
-					break collect
-				}
-				if e.Error != nil {
-					out <- e
-					continue
-				}
-				entries = append(entries, e.Entry)
-			}
+	var entries []Entry
+	var errs []Result
+	for res := range qr.Next() {
+		if res.Error != nil {
+			errs = append(errs, res)
+			continue
 		}
+		entries = append(entries, res.Entry)
+	}
 
-		Sort(orders, entries)
+	Sort(orders, entries)
 
-		for _, e := range entries {
-			select {
-			case <-worker.Closing():
-				return
-			case out <- Result{Entry: e}:
+	return ResultsFromIterator(qr.Query(), Iterator{
+		Next: func() (Result, bool) {
+			if len(errs) != 0 {
+				errResult := errs[0]
+				errs = errs[1:]
+				return errResult, true
 			}
-		}
+			if len(entries) == 0 {
+				return Result{}, false
+			}
+			next := entries[0]
+			entries = entries[1:]
+			return Result{Entry: next}, true
+		},
 	})
 }