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