Skip to content

Commit 5da5e10

Browse files
committed
* fix XCTWaiter issue in CI
1 parent 52e8d25 commit 5da5e10

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

Tests/SwiftKafkaTests/KafkaPollingSystemTests.swift

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,8 @@ final class KafkaPollingSystemTests: XCTestCase {
5252
let expectation = XCTestExpectation(description: "Poll closure invoked after initial produceMore()")
5353
closureWrapper.wrappedClosure = { expectation.fulfill() }
5454
sut.produceMore()
55-
let result = await XCTWaiter.fulfillment(of: [expectation], timeout: 1)
56-
XCTAssertEqual(result, .completed)
55+
let result = await XCTWaiter().fulfillment(of: [expectation], timeout: 1)
56+
XCTAssertEqual(result, XCTWaiter.Result.completed)
5757
if case .pollAndSleep = sut.nextPollLoopAction() {
5858
// Test passed
5959
} else {
@@ -72,8 +72,8 @@ final class KafkaPollingSystemTests: XCTestCase {
7272
secondExpectation.fulfill()
7373
}
7474
sut.produceMore()
75-
let secondResult = await XCTWaiter.fulfillment(of: [secondExpectation], timeout: 1)
76-
XCTAssertEqual(secondResult, .completed)
75+
let secondResult = await XCTWaiter().fulfillment(of: [secondExpectation], timeout: 1)
76+
XCTAssertEqual(secondResult, XCTWaiter.Result.completed)
7777
if case .pollAndSleep = sut.nextPollLoopAction() {
7878
// Test passed
7979
} else {
@@ -102,8 +102,8 @@ final class KafkaPollingSystemTests: XCTestCase {
102102
let expectation = XCTestExpectation(description: "Poll closure invoked after initial produceMore()")
103103
closureWrapper.wrappedClosure = { expectation.fulfill() }
104104
sut.produceMore()
105-
let result = await XCTWaiter.fulfillment(of: [expectation], timeout: 1)
106-
XCTAssertEqual(result, .completed)
105+
let result = await XCTWaiter().fulfillment(of: [expectation], timeout: 1)
106+
XCTAssertEqual(result, XCTWaiter.Result.completed)
107107
if case .pollAndSleep = sut.nextPollLoopAction() {
108108
// Test passed
109109
} else {
@@ -145,8 +145,8 @@ final class KafkaPollingSystemTests: XCTestCase {
145145
let expectation = XCTestExpectation(description: "Poll closure invoked after initial produceMore()")
146146
closureWrapper.wrappedClosure = { expectation.fulfill() }
147147
sut.produceMore()
148-
let result = await XCTWaiter.fulfillment(of: [expectation], timeout: 1)
149-
XCTAssertEqual(result, .completed)
148+
let result = await XCTWaiter().fulfillment(of: [expectation], timeout: 1)
149+
XCTAssertEqual(result, XCTWaiter.Result.completed)
150150
if case .pollAndSleep = sut.nextPollLoopAction() {
151151
// Test passed
152152
} else {

0 commit comments

Comments
 (0)