results.Close needs to wait for closed signal

gammazero · gammazero · commit b6d542d0afb8 · 2025-02-19T15:25:59.000-10:00
diff --git a/query/query.go b/query/query.go
@@ -185,6 +185,7 @@ func (r *results) Rest() ([]Entry, error) {
 
 func (r *results) Close() {
 	r.cancel()
+	<-r.closed
 }
 
 func (r *results) Query() Query {

Original file line number	Diff line number	Diff line change
`@@ -185,6 +185,7 @@ func (r *results) Rest() ([]Entry, error) {`
`185`	`185`
`186`	`186`	`func (r *results) Close() {`
`187`	`187`	`r.cancel()`
	`188`	`+ <-r.closed`
`188`	`189`	`}`
`189`	`190`
`190`	`191`	`func (r *results) Query() Query {`