class Async::Task

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