class Async::Reactor
def run(*arguments, **options, &block)
def run(*arguments, **options, &block) raise RuntimeError, 'Reactor has been closed' if @selector.nil? @scheduler&.set! initial_task = self.async(*arguments, **options, &block) if block_given? while self.run_once # Round and round we go! end return initial_task ensure @scheduler&.clear! Console.logger.debug(self) {"Exiting run-loop because #{$! ? $! : 'finished'}."} end