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.method, request.headers)
		@persistent = false
	end
	
	return request
rescue Async::TimeoutError
	# For an interesting discussion about this behaviour, see https://trac.nginx.org/nginx/ticket/1005
	# If you enable this, you will see some spec failures...
	# fail_request(408)
	raise
rescue
	fail_request(400)
	raise
end