class Async::Scheduler

def self.supported?
	true
end

def self.supported?
	false
end

def block(blocker, timeout)
	@reactor.block(blocker, timeout)
end

def clear!
	Fiber.set_scheduler(nil)
end

def close
end

def fiber(&block)
	task = Task.new(@reactor, &block)
	
	fiber = task.fiber
	
	task.run
	
	return fiber
end

def from_io(io)
.new(io, @reactor)

def initialize(reactor)
	@reactor = reactor
end

def io_wait(io, events, timeout = nil)
	wrapper = from_io(io)
	
	if events == ::IO::READABLE
		if wrapper.wait_readable(timeout)
			return ::IO::READABLE
		end
	elsif events == ::IO::WRITABLE
		if wrapper.wait_writable(timeout)
			return ::IO::WRITABLE
		end
	else
		if wrapper.wait_any(timeout)
			return events
		end
	end
	
	return false
ensure
	wrapper.reactor = nil
end

def kernel_sleep(duration)
	self.block(nil, duration)
end

def process_wait(pid, flags)
	Thread.new do
		::Process::Status.wait(pid, flags)
	end.value
end

def set!
	Fiber.set_scheduler(self)
end

def unblock(blocker, fiber)
	@reactor.unblock(blocker, fiber)
end