class Async::Task

def with(io)

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