class

ScheduleRuntime

Inherits Reference < Object

Constructors

new(schedule : ScheduleState, clock : Clock, mailer : TaskMailer = TaskMailer.new)
Source

Instance methods

handle_event(event : SchedulerEvent) : Bool
Source
handle_task_stopped(event : TaskStoppedEvent)
Source
next_wake_timeout(reasons : Array(TaskRunDecision)) : Time::Span
Source
run(events : Channel(SchedulerEvent) | Nil = nil)
Source
run_due_tasks(events : Channel(SchedulerEvent))
Source
shortest_timeout
Source