Simulate Room RxJava read timeout in happy path

room-rxjava-timeout-happy-path.kt

import io.reactivex.BackpressureStrategy
import io.reactivex.Flowable
import io.reactivex.schedulers.Schedulers
import java.util.concurrent.TimeUnit

fun main() {
    getFakeRoomReadStream()
        .filter { it < 3 }
        .timeout(2L, TimeUnit.SECONDS, Schedulers.io())
        .observeOn(Schedulers.trampoline())
        .subscribe({
            println("succcess $it")
        }, {
            it.printStackTrace()
        })
}

fun getFakeRoomReadStream(): Flowable<Int> {
    return Flowable.create<Int>({
        var i = 0
        while (true) {
            it.onNext(i)
            i++
            Thread.sleep(100L)
        }
    }, BackpressureStrategy.BUFFER)
}