@@ -102,7 +102,7 @@ public final class ActorQueue<ActorType: Actor>: @unchecked Sendable {
102102 fileprivate struct ActorTask : Sendable {
103103 init (
104104 executionContext: ActorType ,
105- task: @escaping @Sendable ( isolated ActorType) async -> Void
105+ task: @escaping @Sendable ( isolated ActorType) async -> Void ,
106106 ) {
107107 self . executionContext = executionContext
108108 self . task = task
@@ -152,7 +152,7 @@ extension Task {
152152 public init < ActorType: Actor > (
153153 priority: TaskPriority ? = nil ,
154154 on actorQueue: ActorQueue < ActorType > ,
155- operation: @Sendable @escaping ( isolated ActorType) async -> Success
155+ operation: @Sendable @escaping ( isolated ActorType) async -> Success ,
156156 ) where Failure == Never {
157157 let delivery = Delivery < Success , Failure > ( )
158158 let semaphore = Semaphore ( )
@@ -163,7 +163,7 @@ extension Task {
163163 delivery. execute ( { @Sendable executionContext in
164164 await delivery. sendValue ( operation ( executionContext) )
165165 } , in: executionContext, priority: priority)
166- }
166+ } ,
167167 )
168168 actorQueue. taskStreamContinuation. yield ( task)
169169 self . init ( priority: priority) {
@@ -172,7 +172,7 @@ extension Task {
172172 await semaphore. signal ( )
173173 return await delivery. getValue ( )
174174 } ,
175- onCancel: delivery. cancel
175+ onCancel: delivery. cancel,
176176 )
177177 }
178178 }
@@ -207,7 +207,7 @@ extension Task {
207207 public init < ActorType: Actor > (
208208 priority: TaskPriority ? = nil ,
209209 on actorQueue: ActorQueue < ActorType > ,
210- operation: @escaping @Sendable ( isolated ActorType) async throws -> Success
210+ operation: @escaping @Sendable ( isolated ActorType) async throws -> Success ,
211211 ) where Failure == any Error {
212212 let delivery = Delivery < Success , Failure > ( )
213213 let semaphore = Semaphore ( )
@@ -222,7 +222,7 @@ extension Task {
222222 await delivery. sendFailure ( error)
223223 }
224224 } , in: executionContext, priority: priority)
225- }
225+ } ,
226226 )
227227 actorQueue. taskStreamContinuation. yield ( task)
228228 self . init ( priority: priority) {
@@ -231,7 +231,7 @@ extension Task {
231231 await semaphore. signal ( )
232232 return try await delivery. getValue ( )
233233 } ,
234- onCancel: delivery. cancel
234+ onCancel: delivery. cancel,
235235 )
236236 }
237237 }
@@ -266,7 +266,7 @@ extension Task {
266266 public init (
267267 priority: TaskPriority ? = nil ,
268268 on actorQueue: ActorQueue < MainActor > ,
269- operation: @MainActor @escaping ( ) async -> Success
269+ operation: @MainActor @escaping ( ) async -> Success ,
270270 ) where Failure == Never {
271271 let delivery = Delivery < Success , Failure > ( )
272272 let semaphore = Semaphore ( )
@@ -277,7 +277,7 @@ extension Task {
277277 delivery. execute ( { @Sendable executionContext in
278278 await delivery. sendValue ( operation ( ) )
279279 } , in: executionContext, priority: priority)
280- }
280+ } ,
281281 )
282282 actorQueue. taskStreamContinuation. yield ( task)
283283 self . init ( priority: priority) {
@@ -286,7 +286,7 @@ extension Task {
286286 await semaphore. signal ( )
287287 return await delivery. getValue ( )
288288 } ,
289- onCancel: delivery. cancel
289+ onCancel: delivery. cancel,
290290 )
291291 }
292292 }
@@ -321,7 +321,7 @@ extension Task {
321321 public init (
322322 priority: TaskPriority ? = nil ,
323323 on actorQueue: ActorQueue < MainActor > ,
324- operation: @escaping @MainActor ( ) async throws -> Success
324+ operation: @escaping @MainActor ( ) async throws -> Success ,
325325 ) where Failure == any Error {
326326 let delivery = Delivery < Success , Failure > ( )
327327 let semaphore = Semaphore ( )
@@ -336,7 +336,7 @@ extension Task {
336336 await delivery. sendFailure ( error)
337337 }
338338 } , in: executionContext, priority: priority)
339- }
339+ } ,
340340 )
341341 actorQueue. taskStreamContinuation. yield ( task)
342342 self . init ( priority: priority) {
@@ -345,7 +345,7 @@ extension Task {
345345 await semaphore. signal ( )
346346 return try await delivery. getValue ( )
347347 } ,
348- onCancel: delivery. cancel
348+ onCancel: delivery. cancel,
349349 )
350350 }
351351 }
0 commit comments