wip

Author: stephencelis

Sources/_StructuredQueriesSQLite/DatabaseFunction.swift

@@ -126,7 +126,9 @@ private final class AggregateDatabaseFunctionIterator<
 >: AggregateDatabaseFunctionIteratorProtocol {
   let body: Body
   let stream = Stream<Body.Row>()
-  let queue = DispatchQueue.global(qos: .userInitiated)
+  let queue = DispatchQueue(
+    label: "co.pointfree.StructuredQueriesSQLite.AggregateDatabaseFunction"
+  )
   var _result: QueryBinding?
   init(_ body: Body) {
     self.body = body

Tests/StructuredQueriesTests/DatabaseFunctionTests.swift

@@ -554,5 +554,29 @@ extension SnapshotTests {
         """
       }
     }
+
+    @DatabaseFunction
+    func tagged(_ tags: some Sequence<Tag>) -> String {
+      tags.map { "#\($0.title)" }.joined(separator: " ")
+    }
+
+    @Test func selectionTableAggregate() {
+      $tagged.install(database.handle)
+
+      assertQuery(
+        Tag.select { $tagged($0) }
+      ) {
+        """
+        SELECT "tagged"("tags"."id", "tags"."title")
+        FROM "tags"
+        """
+      } results: {
+        """
+        ┌─────────────────────────────────┐
+        │ "#car #kids #someday #optional" │
+        └─────────────────────────────────┘
+        """
+      }
+    }
   }
 }