File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
Tests/TecoCLSLoggingTests Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -38,7 +38,7 @@ public class CLSLogQueue {
38
38
let errorStorageLock = NIOLock ( )
39
39
let errorStorage : UnsafeMutableTransferBox < Error ? > = . init( nil )
40
40
let continuation = DispatchWorkItem { }
41
- Task . detached {
41
+ Task {
42
42
do {
43
43
while let payload = self . batchUploadPayload ( force: true ) {
44
44
_ = try await self . uploader ( payload)
Original file line number Diff line number Diff line change @@ -4,12 +4,12 @@ import AsyncHTTPClient
4
4
import Atomics
5
5
6
6
final class CLSLogQueueTests : XCTestCase {
7
- func testBatchSize( ) async throws {
7
+ func testBatchSize( ) throws {
8
8
// set up test helpers
9
9
let batches = ManagedAtomic ( 0 )
10
10
func upload( _ logs: [ Cls_LogGroup ] ) throws -> String {
11
11
XCTAssertLessThanOrEqual ( logs. count, 2 )
12
- batches. wrappingIncrement ( ordering: . relaxed )
12
+ batches. wrappingIncrement ( ordering: . sequentiallyConsistent )
13
13
return " mock-upload-id "
14
14
}
15
15
@@ -29,7 +29,7 @@ final class CLSLogQueueTests: XCTestCase {
29
29
try queue. forceFlush ( )
30
30
31
31
// assert batch counts
32
- XCTAssertEqual ( batches. load ( ordering: . acquiring ) , 6 )
32
+ XCTAssertEqual ( batches. load ( ordering: . sequentiallyConsistent ) , 6 )
33
33
}
34
34
35
35
func testWaitDuration( ) async throws {
You can’t perform that action at this time.
0 commit comments