Async::Cron SourceAsyncCronServiceScheduler

class Scheduler

Definitions

def setup(container)

Setup the container with the application instance.

Signature

parameter container Async::Container::Generic

Implementation

def setup(container)
	container_options = @evaluator.container_options
	
	container.run(name: self.name, **container_options) do |instance|
		evaluator = @environment.evaluator
		
		Async do |task|
			scheduler = evaluator.scheduler
			
			task = Async do
				scheduler.run
			end
			
			instance.ready!
			
			task.wait
		end
	end
end