refactor: use standardized swift-async-algorithms

Adopts the more common (now-a-days) swift-async-algorithms for the simple
async collection needs of this package. Helps adopt the standardized
ecosystem where many other packages use swift-async-algorithms.

Author: Austinpayne

Package.resolved

@@ -12,7 +12,7 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/apple/swift-algorithms.git", from: "1.0.0"),
-        .package(url: "https://github.com/adam-fowler/async-collections", from: "0.0.1"),
+        .package(url: "https://github.com/apple/swift-async-algorithms.git", from: "1.0.0"),
         .package(url: "https://github.com/apple/swift-nio.git", from: "2.0.0"),
     ],
     targets: [
@@ -27,7 +27,7 @@ let package = Package(
             name: "AsyncDataLoader",
             dependencies: [
                 .product(name: "Algorithms", package: "swift-algorithms"),
-                .product(name: "AsyncCollections", package: "async-collections"),
+                .product(name: "AsyncAlgorithms", package: "swift-async-algorithms"),
             ]
         ),
         .testTarget(name: "DataLoaderTests", dependencies: ["DataLoader"]),

Package.swift

@@ -1,5 +1,5 @@
 import Algorithms
-import AsyncCollections
+import AsyncAlgorithms
 
 public enum DataLoaderValue<T: Sendable>: Sendable {
     case success(T)
@@ -117,7 +117,7 @@ public actor DataLoader<Key: Hashable & Sendable, Value: Sendable> {
             return []
         }
 
-        return try await keys.concurrentMap { try await self.load(key: $0) }
+        return try await Array(keys.async.map { try await self.load(key: $0) })
     }
 
     /// Clears the value at `key` from the cache, if it exists. Returns itself for
@@ -177,8 +177,8 @@ public actor DataLoader<Key: Hashable & Sendable, Value: Sendable> {
         // If a maxBatchSize was provided and the queue is longer, then segment the
         // queue into multiple batches, otherwise treat the queue as a single batch.
         if let maxBatchSize = options.maxBatchSize, maxBatchSize > 0, maxBatchSize < batch.count {
-            try await batch.chunks(ofCount: maxBatchSize).asyncForEach { slicedBatch in
-                try await self.executeBatch(batch: Array(slicedBatch))
+            for try await slicedBatch in batch.chunks(ofCount: maxBatchSize).async {
+                try await executeBatch(batch: Array(slicedBatch))
             }
         } else {
             try await executeBatch(batch: batch)