elizarov
06/17/2017, 3:08 PMsealed class SchedulerMessage<T> {
open val receiver: (T) -> Unit
open val msg: T
open val initialDelay: Duration
open val replayCh: Channel<Job>
}
class Schedule<T>(
override val receiver: (T) -> Unit,
override val msg: T,
override val initialDelay: Duration,
override val replayCh: Channel<Job>,
override val delayBetween: Duration
) : SchedulerMessage<T>()
class ScheduleOnce<T>(
override val receiver: (T) -> Unit,
override val msg: T,
override val initialDelay: Duration,
override val replayCh: Channel<Job>
) : SchedulerMessage<T>()