class Async::Container::Supervisor::Service
def setup(container)
def setup(container) container_options = @evaluator.container_options health_check_timeout = container_options[:health_check_timeout] container.run(name: self.name, **container_options) do |instance| evaluator = @environment.evaluator Async do server = evaluator.make_server(@bound_endpoint) server.run instance.ready! if health_check_timeout Async(transient: true) do while true sleep(health_check_timeout / 2) instance.ready! end end end end end super end