We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c4aca20 commit cc0e14cCopy full SHA for cc0e14c
Tests/SwiftKafkaTests/KafkaPollingSystemTests.swift
@@ -179,18 +179,6 @@ final class KafkaPollingSystemTests: XCTestCase {
179
}
180
181
182
- // Produce elements until we reach the high watermark
183
- // should work fine.
184
- for num in 1...4 {
185
- sut.yield(num)
186
- XCTAssertTrue(Self.isPollAndSleep(sut.nextPollLoopAction()))
187
- }
188
-
189
- // Producing this element makes us reach the high watermark.
190
- // The poll loop should suspend now.
191
- sut.yield(5)
192
- XCTAssertTrue(Self.isSuspendPollLoop(sut.nextPollLoopAction()))
193
194
// Cancel the Task that runs the poll loop.
195
// This should result in the poll loop shutting down.
196
runTask.cancel()
0 commit comments