› Async › Source › Async › Reactor

class Reactor

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(...)
	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

Discussion