class Reactor < Scheduler
- Inherits from
Scheduler
Inherited Methods
From Async::Scheduler:
#load#terminate#close#closed?#to_s#interrupt#transfer#yield#push#raise#resume#block#unblock#kernel_sleep#address_resolve#io_wait#io_read#io_write#fiber_interrupt#process_wait#io_select#run_once#cancel#stop#run#async#fiber#with_timeout#timeout_after#process_fork.supported?
From Async::Node:
A wrapper around the the scheduler which binds it to the current thread automatically.
Definitions
def self.run(...)
- deprecated
Signature
- deprecated
Replaced by
Kernel#Async.
Implementation
def self.run(...)
warn("`Async::Reactor.run{}` is deprecated, use `Async{}` instead.", uplevel: 1, category: :deprecated) if $VERBOSE
Async(...)
end
def initialize(...)
Initialize the reactor and assign it to the current Fiber scheduler.
Implementation
def initialize(...)
super
Fiber.set_scheduler(self)
end
def scheduler_close
Close the reactor and remove it from the current Fiber scheduler.
Implementation
def scheduler_close
self.close
end