Function countQueryResults

db/query_test.go:343–351

(ctx context.Context, results sgbucket.QueryResultIterator)

}

func countQueryResults(ctx context.Context, results sgbucket.QueryResultIterator) int {

	count := 0
	var row map[string]interface{}
	for results.Next(ctx, &row) {
		count++
	}
	return count
}

func TestQueryChannelsActiveOnlyWithLimit(t *testing.T) {
	if base.TestsDisableGSI() {