class Reactor < Scheduler
- Inherits from
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, #root, #children?, #transient?, #transient=, #annotate, #description, #backtrace, #parent=, #finished?, #consume, #traverse, #wait, #cancelled?, #stopped?, #print_hierarchy, .supported?
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