Infinite Rx Sequence Usage

rx_infinite.kt

@Test
fun rx_infinite() {
    val testSub = TestSubscriber<Int>()

    var start = 0
    fun inc(): Int {
        start += 1
        return start
    }

    Observable.just(1).repeat().flatMap {
        Observable.just(inc())
    }.take(4).subscribe(testSub)

    testSub.assertCompleted()
    testSub.assertValueCount(4)
    testSub.assertValues(1, 2, 3, 4)
}