Я использовал Single observable с Rx Java для сетевых задач. Я видел, что тип Observable предоставляет API для установки таймера и интервалов, как в следующем примере.
Observable.interval(0, 2, TimeUnit.SECONDS)
.take(5)
.flatMap {
return@flatMap Observable.create<String> { emitter ->
emitter.onNext("Hello, me")
emitter.onComplete()
}
}
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
Log.d("IntervalExample", it)
}
Предоставляет ли Single type аналогичные API? Я мог бы использовать тип Observable, но в настоящее время я могу использовать только один тип. Я искал документацию онлайн, но не смог найти ничего полезного. Спасибо.