我一直在使用RxJava的Single Observable进行网络任务。我已经看到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)
}
单一类型也提供类似的API吗?我可以使用Observable类型,但目前只能使用Single类型。我已经在线搜索了文档,但是找不到任何有用的东西。谢谢。
Single
类型的delaySubscription
方法可能适合您的需求
delaySubscription