Предоставляет ли Single observable API для установки таймера и интервала? - PullRequest
0 голосов
/ 10 апреля 2020

Я использовал 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, но в настоящее время я могу использовать только один тип. Я искал документацию онлайн, но не смог найти ничего полезного. Спасибо.

1 Ответ

0 голосов
/ 10 апреля 2020

Тип Single имеет метод delaySubscription, который может удовлетворить ваши потребности

Single.create(emitter -> emitter.onSuccess("Hello, me"))
.delaySubscription(2, TimeUnit.SECONDS)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...