vaskir
06/17/2017, 3:10 PMsealed class SchedulerMessage<T>
class Schedule<T>(
val receiver: (T) -> Unit,
val msg: T,
val initialDelay: Duration,
val delayBetween: Duration,
val replayCh: Channel<Job>
) : SchedulerMessage<T>()
class ScheduleOnce<T>(
val receiver: (T) -> Unit,
val msg: T,
val initialDelay: Duration,
val replayCh: Channel<Job>
) : SchedulerMessage<T>()