class Async::Task
def async(*args, **options, &block)
def async(*args, **options, &block) task = Task.new(@reactor, self, **options, &block) task.run(*args) return task end
def async(*args, **options, &block) task = Task.new(@reactor, self, **options, &block) task.run(*args) return task end