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 acbf5e9 commit f518175Copy full SHA for f518175
client/src/test/kotlin/io/hstream/impl/ResponderImplTest.kt
@@ -9,6 +9,7 @@ import kotlinx.coroutines.runBlocking
9
import org.junit.jupiter.api.AfterEach
10
import org.junit.jupiter.api.Assertions.assertEquals
11
import org.junit.jupiter.api.BeforeEach
12
+import org.junit.jupiter.api.Disabled
13
import org.junit.jupiter.api.Test
14
import org.junit.runner.RunWith
15
import org.mockito.junit.MockitoJUnitRunner
@@ -75,6 +76,7 @@ class ResponderImplTest {
75
76
}
77
78
@Test
79
+ @Disabled("should not dependent on async timers")
80
fun `when ackAgeLimit is set, and ackBufferSize is set to very large, ACKs should send by age limit`() {
81
val xs = buildBlackBoxSourceClient_()
82
val consumerName = "some-consumer"
0 commit comments