@@ -37,7 +37,8 @@ struct ActorQueueTests {
37
37
38
38
// MARK: Behavior Tests
39
39
40
- @Test func test_adoptExecutionContext_doesNotRetainActor( ) {
40
+ @Test
41
+ func adoptExecutionContext_doesNotRetainActor( ) {
41
42
let systemUnderTest = ActorQueue < Counter > ( )
42
43
var counter : Counter ? = Counter ( )
43
44
weak var weakCounter = counter
@@ -46,7 +47,8 @@ struct ActorQueueTests {
46
47
#expect( weakCounter == nil )
47
48
}
48
49
49
- @Test func test_task_retainsAdoptedActorUntilEnqueuedTasksComplete( ) async {
50
+ @Test
51
+ func task_retainsAdoptedActorUntilEnqueuedTasksComplete( ) async {
50
52
let systemUnderTest = ActorQueue < Counter > ( )
51
53
var counter : Counter ? = Counter ( )
52
54
weak var weakCounter = counter
@@ -62,7 +64,8 @@ struct ActorQueueTests {
62
64
await semaphore. signal ( )
63
65
}
64
66
65
- @Test func test_throwingTask_retainsAdoptedActorUntilEnqueuedTasksComplete( ) async {
67
+ @Test
68
+ func throwingTask_retainsAdoptedActorUntilEnqueuedTasksComplete( ) async {
66
69
let systemUnderTest = ActorQueue < Counter > ( )
67
70
var counter : Counter ? = Counter ( )
68
71
weak var weakCounter = counter
@@ -79,7 +82,8 @@ struct ActorQueueTests {
79
82
await semaphore. signal ( )
80
83
}
81
84
82
- @Test func test_task_taskParameterIsAdoptedActor( ) async {
85
+ @Test
86
+ func task_taskParameterIsAdoptedActor( ) async {
83
87
let semaphore = Semaphore ( )
84
88
Task ( on: systemUnderTest) { [ storedCounter = counter] counter in
85
89
#expect( counter === storedCounter)
@@ -89,7 +93,8 @@ struct ActorQueueTests {
89
93
await semaphore. wait ( )
90
94
}
91
95
92
- @Test func test_throwingTask_taskParameterIsAdoptedActor( ) async {
96
+ @Test
97
+ func throwingTask_taskParameterIsAdoptedActor( ) async {
93
98
let semaphore = Semaphore ( )
94
99
Task ( on: systemUnderTest) { [ storedCounter = counter] counter in
95
100
#expect( counter === storedCounter)
@@ -100,7 +105,8 @@ struct ActorQueueTests {
100
105
await semaphore. wait ( )
101
106
}
102
107
103
- @Test func test_task_sendsEventsInOrder( ) async throws {
108
+ @Test
109
+ func task_sendsEventsInOrder( ) async throws {
104
110
var lastTask : Task < Void , Never > ?
105
111
( 1 ... 1_000 ) . forEach { iteration in
106
112
lastTask = Task ( on: systemUnderTest) { counter in
@@ -111,7 +117,8 @@ struct ActorQueueTests {
111
117
try await #require( lastTask) . value
112
118
}
113
119
114
- @Test func test_throwingTask_sendsEventsInOrder( ) async throws {
120
+ @Test
121
+ func throwingTask_sendsEventsInOrder( ) async throws {
115
122
var lastTask : Task < Void , Error > ?
116
123
( 1 ... 1_000 ) . forEach { iteration in
117
124
lastTask = Task ( on: systemUnderTest) { counter in
@@ -124,7 +131,8 @@ struct ActorQueueTests {
124
131
}
125
132
126
133
@TestingQueue
127
- @Test func test_mainTask_sendsEventsInOrder( ) async throws {
134
+ @Test
135
+ func mainTask_sendsEventsInOrder( ) async throws {
128
136
var lastTask : Task < Void , Error > ?
129
137
( 1 ... 1_000 ) . forEach { iteration in
130
138
lastTask = Task ( on: MainActor . queue) {
@@ -136,7 +144,8 @@ struct ActorQueueTests {
136
144
}
137
145
138
146
@TestingQueue
139
- @Test func test_mainThrowingTask_sendsEventsInOrder( ) async throws {
147
+ @Test
148
+ func mainThrowingTask_sendsEventsInOrder( ) async throws {
140
149
var lastTask : Task < Void , Error > ?
141
150
( 1 ... 1_000 ) . forEach { iteration in
142
151
lastTask = Task ( on: MainActor . queue) {
@@ -148,7 +157,8 @@ struct ActorQueueTests {
148
157
try await #require( lastTask) . value
149
158
}
150
159
151
- @Test func test_task_startsExecutionOfNextTaskAfterSuspension( ) async {
160
+ @Test
161
+ func task_startsExecutionOfNextTaskAfterSuspension( ) async {
152
162
let systemUnderTest = ActorQueue < AsyncQueue . Semaphore > ( )
153
163
let semaphore = AsyncQueue . Semaphore ( )
154
164
systemUnderTest. adoptExecutionContext ( of: semaphore)
@@ -165,7 +175,8 @@ struct ActorQueueTests {
165
175
( _, _) = await ( firstTask. value, secondTask. value)
166
176
}
167
177
168
- @Test func test_throwingTask_startsExecutionOfNextTaskAfterSuspension( ) async throws {
178
+ @Test
179
+ func throwingTask_startsExecutionOfNextTaskAfterSuspension( ) async throws {
169
180
let systemUnderTest = ActorQueue < AsyncQueue . Semaphore > ( )
170
181
let semaphore = AsyncQueue . Semaphore ( )
171
182
systemUnderTest. adoptExecutionContext ( of: semaphore)
@@ -184,7 +195,8 @@ struct ActorQueueTests {
184
195
( _, _) = try await ( firstTask. value, secondTask. value)
185
196
}
186
197
187
- @Test func test_task_allowsReentrancy( ) async {
198
+ @Test
199
+ func task_allowsReentrancy( ) async {
188
200
await Task ( on: systemUnderTest) { [ systemUnderTest] counter in
189
201
await Task ( on: systemUnderTest) { counter in
190
202
counter. incrementAndExpectCount ( equals: 1 )
@@ -193,7 +205,8 @@ struct ActorQueueTests {
193
205
} . value
194
206
}
195
207
196
- @Test func test_throwingTask_allowsReentrancy( ) async throws {
208
+ @Test
209
+ func throwingTask_allowsReentrancy( ) async throws {
197
210
try await Task ( on: systemUnderTest) { [ systemUnderTest] counter in
198
211
try doWork ( )
199
212
try await Task ( on: systemUnderTest) { counter in
@@ -206,7 +219,8 @@ struct ActorQueueTests {
206
219
}
207
220
208
221
@TestingQueue
209
- @Test func test_mainTask_allowsReentrancy( ) async {
222
+ @Test
223
+ func mainTask_allowsReentrancy( ) async {
210
224
await Task ( on: MainActor . queue) { [ counter] in
211
225
await Task ( on: MainActor . queue) {
212
226
await counter. incrementAndExpectCount ( equals: 1 )
@@ -216,7 +230,8 @@ struct ActorQueueTests {
216
230
}
217
231
218
232
@TestingQueue
219
- @Test func test_mainThrowingTask_allowsReentrancy( ) async throws {
233
+ @Test
234
+ func mainThrowingTask_allowsReentrancy( ) async throws {
220
235
try await Task ( on: MainActor . queue) { [ counter] in
221
236
try doWork ( )
222
237
try await Task ( on: MainActor . queue) {
@@ -228,7 +243,8 @@ struct ActorQueueTests {
228
243
} . value
229
244
}
230
245
231
- @Test func test_task_executesEnqueuedTasksAfterQueueIsDeallocated( ) async throws {
246
+ @Test
247
+ func task_executesEnqueuedTasksAfterQueueIsDeallocated( ) async throws {
232
248
var systemUnderTest : ActorQueue < Counter > ? = ActorQueue ( )
233
249
systemUnderTest? . adoptExecutionContext ( of: counter)
234
250
@@ -249,7 +265,8 @@ struct ActorQueueTests {
249
265
await expectation. fulfillment ( withinSeconds: 30 )
250
266
}
251
267
252
- @Test func test_throwingTask_executesEnqueuedTasksAfterQueueIsDeallocated( ) async throws {
268
+ @Test
269
+ func throwingTask_executesEnqueuedTasksAfterQueueIsDeallocated( ) async throws {
253
270
var systemUnderTest : ActorQueue < Counter > ? = ActorQueue ( )
254
271
systemUnderTest? . adoptExecutionContext ( of: counter)
255
272
@@ -272,21 +289,24 @@ struct ActorQueueTests {
272
289
await expectation. fulfillment ( withinSeconds: 30 )
273
290
}
274
291
275
- @Test func test_task_canReturn( ) async {
292
+ @Test
293
+ func task_canReturn( ) async {
276
294
let expectedValue = UUID ( )
277
295
let returnedValue = await Task ( on: systemUnderTest) { _ in expectedValue } . value
278
296
#expect( expectedValue == returnedValue)
279
297
}
280
298
281
- @Test func test_throwingTask_canReturn( ) async throws {
299
+ @Test
300
+ func throwingTask_canReturn( ) async throws {
282
301
let expectedValue = UUID ( )
283
302
@Sendable func generateValue( ) throws -> UUID {
284
303
expectedValue
285
304
}
286
305
#expect( try await Task ( on: systemUnderTest) { _ in try generateValue ( ) } . value == expectedValue)
287
306
}
288
307
289
- @Test func test_throwingTask_canThrow( ) async {
308
+ @Test
309
+ func throwingTask_canThrow( ) async {
290
310
struct TestError : Error , Equatable {
291
311
private let identifier = UUID ( )
292
312
}
@@ -298,7 +318,8 @@ struct ActorQueueTests {
298
318
}
299
319
}
300
320
301
- @Test func test_mainThrowingTask_canThrow( ) async {
321
+ @Test
322
+ func mainThrowingTask_canThrow( ) async {
302
323
struct TestError : Error , Equatable {
303
324
private let identifier = UUID ( )
304
325
}
@@ -310,15 +331,17 @@ struct ActorQueueTests {
310
331
}
311
332
}
312
333
313
- @Test func test_mainTask_executesOnMainActor( ) async {
334
+ @Test
335
+ func mainTask_executesOnMainActor( ) async {
314
336
@MainActor
315
337
func executesOnMainActor( ) { }
316
338
await Task ( on: MainActor . queue) {
317
339
executesOnMainActor ( )
318
340
} . value
319
341
}
320
342
321
- @Test func test_mainThrowingTask_executesOnMainActor( ) async throws {
343
+ @Test
344
+ func mainThrowingTask_executesOnMainActor( ) async throws {
322
345
@MainActor
323
346
func executesOnMainActor( ) throws { }
324
347
try await Task ( on: MainActor . queue) {
0 commit comments