Skip to content

Commit dac399e

Browse files
committed
lint
1 parent a28a8e7 commit dac399e

File tree

1 file changed

+24
-6
lines changed

1 file changed

+24
-6
lines changed

Test/AwsCommonRuntimeKitTests/mqtt/Mqtt5ClientTests.swift

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2350,8 +2350,14 @@ class Mqtt5ClientTests: XCBaseTestCase, @unchecked Sendable {
23502350
}
23512351

23522352
let callbackCompleted = await withTaskGroup(of: Bool.self) { group in
2353-
group.addTask { await callbackDoneSemaphore.wait(); return true }
2354-
group.addTask { try? await Task.sleep(nanoseconds: 10_000_000_000); return false }
2353+
group.addTask {
2354+
await callbackDoneSemaphore.wait();
2355+
return true
2356+
}
2357+
group.addTask {
2358+
try? await Task.sleep(nanoseconds: 10_000_000_000);
2359+
return false
2360+
}
23552361
let completed = await group.next()!
23562362
group.cancelAll()
23572363
return completed
@@ -2433,8 +2439,14 @@ class Mqtt5ClientTests: XCBaseTestCase, @unchecked Sendable {
24332439

24342440
// Wait for the callback to complete (with timeout to prevent hanging in CI)
24352441
let callbackCompleted = await withTaskGroup(of: Bool.self) { group in
2436-
group.addTask { await callbackDoneSemaphore.wait(); return true }
2437-
group.addTask { try? await Task.sleep(nanoseconds: 10_000_000_000); return false }
2442+
group.addTask {
2443+
await callbackDoneSemaphore.wait();
2444+
return true
2445+
}
2446+
group.addTask {
2447+
try? await Task.sleep(nanoseconds: 10_000_000_000);
2448+
return false
2449+
}
24382450
let completed = await group.next()!
24392451
group.cancelAll()
24402452
return completed
@@ -2524,8 +2536,14 @@ class Mqtt5ClientTests: XCBaseTestCase, @unchecked Sendable {
25242536
}
25252537

25262538
let callbackCompleted = await withTaskGroup(of: Bool.self) { group in
2527-
group.addTask { await callbackDoneSemaphore.wait(); return true }
2528-
group.addTask { try? await Task.sleep(nanoseconds: 10_000_000_000); return false }
2539+
group.addTask {
2540+
await callbackDoneSemaphore.wait();
2541+
return true
2542+
}
2543+
group.addTask {
2544+
try? await Task.sleep(nanoseconds: 10_000_000_000);
2545+
return false
2546+
}
25292547
let completed = await group.next()!
25302548
group.cancelAll()
25312549
return completed

0 commit comments

Comments
 (0)