kdocs/dev.inmo.krontab/LambdaKronSchedulerTz

LambdaKronSchedulerTz

class LambdaKronSchedulerTz(onNext: suspend (<Error class: unknown class>) -> <Error class: unknown class>?) : KronSchedulerTz(source)

Constructors

constructor(onNext: suspend (<Error class: unknown class>) -> <Error class: unknown class>?)

Functions

asFlowWithDelays

fun KronScheduler.asFlowWithDelays(): <Error class: unknown class><<Error class: unknown class>>

This flow is cold

asFlowWithoutDelays

fun KronScheduler.asFlowWithoutDelays(since: <Error class: unknown class> = DateTime.now()): <Error class: unknown class><<Error class: unknown class>>

This flow is cold

asTzFlowWithDelays

fun KronScheduler.asTzFlowWithDelays(): <Error class: unknown class><<Error class: unknown class>>

This flow is cold

asTzFlowWithoutDelays

fun KronScheduler.asTzFlowWithoutDelays(since: <Error class: unknown class> = DateTime.nowLocal()): <Error class: unknown class><<Error class: unknown class>>

This flow is cold

doInfinity

inline suspend fun KronScheduler.doInfinity(noinline block: suspend (<Error class: unknown class>) -> Unit)

Will execute block without any checking of result

doInfinityTz

inline suspend fun KronScheduler.doInfinityTz(noinline block: suspend (<Error class: unknown class>) -> Unit)

Will execute block without any checking of result

doOnce

inline suspend fun <T> KronScheduler.doOnce(noinline block: suspend (<Error class: unknown class>) -> T): T

Execute block once at the KronScheduler.next time and return result of block calculation.

doOnceTz

inline suspend fun <T> KronScheduler.doOnceTz(noinline block: suspend (<Error class: unknown class>) -> T): T

Execute block once at the KronScheduler.next time and return result of block calculation.

doWhile

inline suspend fun KronScheduler.doWhile(noinline block: suspend (<Error class: unknown class>) -> Boolean)

Will execute block while it will return true as a result of its calculation

doWhileTz

inline suspend fun KronScheduler.doWhileTz(noinline block: suspend (<Error class: unknown class>) -> Boolean)

Will execute block while it will return true as a result of its calculation

open suspend override fun next(relatively: <Error class: unknown class>): <Error class: unknown class>?

suspend fun KronScheduler.next(relatively: <Error class: unknown class>): <Error class: unknown class>

nextOrNow

suspend fun KronScheduler.nextOrNow(): <Error class: unknown class>

nextOrNowWithOffset

suspend fun KronSchedulerTz.nextOrNowWithOffset(): <Error class: unknown class>

nextOrRelative

suspend fun KronScheduler.nextOrRelative(relatively: <Error class: unknown class> = DateTime.now()): <Error class: unknown class>

suspend fun KronSchedulerTz.nextOrRelative(relatively: <Error class: unknown class>): <Error class: unknown class>

nextTimeZoned

suspend fun KronScheduler.nextTimeZoned(): <Error class: unknown class>?

plus

operator fun KronScheduler.plus(kronScheduler: KronScheduler): CollectionKronScheduler