RxJava Unit test Observable interval
I have a network polling function with Observable interval in my repository
class repository @Inject constructor(
private val api: api,
private val schedulerProvider: SchedulerProvider
) {
private fun networkPoll(): Observable {
return Observable.interval(1L, TimeUnit.Seconds,
schedulerProvider.io())
.startWith(0L)
.flatMap {
api.getStatus().subscribeOn(
schedulerProvider.io()).toObservable()
}
}
private fun...