Add AsyncSequence.collect()

Sources/NiceThings/Extensions/Concurrency/AsyncSequence+Collect.swift

@@ -0,0 +1,13 @@
+//
+//  AsyncSequence+Collect.swift
+//  
+//
+//  Created by Jesse Tipton on 12/10/22.
+//
+
+@available(iOS 13, macOS 10.15, tvOS 13, watchOS 6, *)
+extension AsyncSequence {
+    public func collect() async rethrows -> [Element] {
+        try await reduce(into: [Element]()) { $0.append($1) }
+    }
+}

Tests/NiceThingsTests/Extensions/Concurrency/AsyncSequenceCollectTests.swift

@@ -0,0 +1,37 @@
+//
+//  AsyncSequenceCollectTests.swift
+//  
+//
+//  Created by Jesse Tipton on 12/10/22.
+//
+
+import XCTest
+import NiceThings
+
+final class AsyncSequenceCollectTests: XCTestCase {
+    func testCollect() async {
+        let stream = AsyncStream { continuation in
+            continuation.yield(1)
+            continuation.yield(2)
+            continuation.yield(3)
+            continuation.finish()
+        }
+
+        let output = await stream.collect()
+
+        XCTAssertEqual(output, [1, 2, 3])
+    }
+
+    func testCollectOnThrowingSequence() async throws {
+        let throwingStream = AsyncThrowingStream { continuation in
+            continuation.yield(1)
+            continuation.yield(2)
+            continuation.yield(3)
+            continuation.finish()
+        }
+
+        let output = try await throwingStream.collect()
+
+        XCTAssertEqual(output, [1, 2, 3])
+    }
+}