lib/kernel/async.rb in async-2.15.3 vs lib/kernel/async.rb in async-2.16.0
- old
+ new
@@ -22,9 +22,11 @@
# @public Since `stable-v1`.
# @asynchronous May block until given block completes executing.
def Async(...)
if current = ::Async::Task.current?
return current.async(...)
+ elsif scheduler = Fiber.scheduler
+ ::Async::Task.run(scheduler, ...)
else
# This calls Fiber.set_scheduler(self):
reactor = ::Async::Reactor.new
begin