AsyncCollections
Functions for running async processes on Swift Collections
ForEach
Run an async function on every element of a Sequence.
await array.asyncForEach {
await asyncProcess($0)
}
The async closures are run serially ie the closure run on the current element of a sequence has to finish before we run the closure on the next element.
To run the closures concurrently use
try await array.concurrentForEach {
try await asyncProcess($0)
}
Map
Return an array transformed by an async function.
let result = await array.asyncMap {
return await asyncTransform($0)
}
Similar to asyncForEach there is a concurrentMap as well which will run the closures concurrently.
TaskQueue
Use a TaskQueue to manage the number of concurrent tasks when processing a large sequence.
let queue = TaskQueue<Int>(maxConcurrentTasks: 8)
let result = try await array.concurrentMap { value -> Int in
try await queue.add {
return await asyncTransform(value)
}
}
206 Dec 24, 2022
3 Jan 18, 2022
199 Jan 1, 2023
23 Oct 14, 2022
248 Sep 19, 2022
1 Nov 30, 2021
9 Oct 4, 2022
60 Aug 11, 2022
42 Oct 5, 2022
1.5k Dec 22, 2022
25 May 24, 2019
814 Oct 30, 2022
80 Dec 14, 2022
137 Dec 16, 2022
9 Jan 3, 2023
1 Feb 9, 2022
2 Jul 30, 2022
20 Jan 3, 2023
421 Jun 30, 2022