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