class Async::Scheduler
def run(...)
def run(...) Kernel.raise ClosedError if @selector.nil? initial_task = self.async(...) if block_given? self.run_loop do run_once end return initial_task end
def run(...) Kernel.raise ClosedError if @selector.nil? initial_task = self.async(...) if block_given? self.run_loop do run_once end return initial_task end