class Async::Task

def self.current
	Thread.current[:async_task] or raise RuntimeError, "No async task available!"
end

def self.current?
	Thread.current[:async_task]
end

def bind(io)
	@ios[io.fileno] ||= reactor.wrap(io, self)
end

def close
	@ios.each_value(&:close)
	@ios = []
	
	consume
end

def finished?
	super && @status != :running
end

def initialize(ios, reactor)
	if parent = Task.current?
		super(parent)
	else
		super(reactor)
	end
	
	@ios = Hash[
		ios.collect{|io| [io.fileno, reactor.wrap(io, self)]}
	]
	
	@reactor = reactor
	
	@status = :running
	@result = nil
	
	@fiber = Fiber.new do
		set!
		
		begin
			@result = yield(*@ios.values, self)
			@status = :complete
			# Async.logger.debug("Task #{self} completed normally.")
		rescue Interrupt
			@status = :interrupted
			# Async.logger.debug("Task #{self} interrupted: #{$!}")
		rescue Exception
			@status = :failed
			# Async.logger.debug("Task #{self} failed: #{$!}")
			raise
		ensure
			# Async.logger.debug("Task #{self} closing: #{$!}")
			close
		end
	end
end

def register(io, interests)
	@reactor.register(io, interests)
end

def run
	@fiber.resume
		
	return @fiber
end

def set!
	# This is actually fiber-local:
	Thread.current[:async_task] = self
end

def stop
	@children.each(&:stop)
	
	if @fiber.alive?
		exception = Interrupt.new("Stop right now!")
		@fiber.resume(exception)
	end
end

def to_s
	"#{super}[#{@status}]"
end

def with(io)
	wrapper = @reactor.wrap(io, self)
	
	yield wrapper
ensure
	wrapper.close
	io.close
end