debounce

timeout

@Test
fun `'debounce' using Main scheduler works`() {
    val timeout = 10L
    val time = getTimeMillis()
    val wasCalled = AtomicBoolean(false)

    observableOf(1, 2, 3, 4, 5)
        .debounce(timeout, mainScheduler)
        .subscribe { value ->
            val elapsed = getTimeMillis() - time
            assertTrue("Should have passed more than $timeout millis, but was $elapsed") { elapsed >= timeout }
            assertEquals(5, value)

            wasCalled.value = true
        }

    await(2*timeout.toInt())
    assertTrue("`subscribe` was not called") { wasCalled.value }
}

kotlin.AssertionError: Should have passed more than 10 millis, but was 1

ioScheduler

computationScheduler

delay

debounce

await

private fun await(millis: Int) {
    NSRunLoop.currentRunLoop.runUntilDate(NSDate.dateWithTimeInterval(millis.toDouble()/1000.0, NSDate.now))
}

5

timeout

observable<Int> { (1..5).forEach(it::onNext) }