Single observable是否提供API来设置计时器和间隔

Question

我一直在使用带有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)
}

Single type是否也提供类似的API？我可以使用Observable类型，但我目前只能使用Single类型。我在网上搜索过文件，但找不到任何有用的东西。谢谢

Answer 1

Single类型有一个delaySubscription方法，可以满足您的需求

Single.create(emitter -> emitter.onSuccess("Hello, me"))
.delaySubscription(2, TimeUnit.SECONDS)