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