class Async::HTTP::Protocol::HTTP1::Server

def next_request
	# The default is true.
	return unless @persistent
	
	# Read an incoming request:
	return unless request = Request.read(self)
	
	unless persistent?(request.version, request.headers)
		@persistent = false
	end
	
	return request
rescue Async::TimeoutError
	fail_request(408)
	raise
rescue
	fail_request(400)
	raise
end