class Async::HTTP::Protocol::HTTP11

def receive_requests(task: Task.current)
	while request = next_request
		if response = yield(request, self)
			write_response(self.version, response.status, response.headers, response.body)
			request.finish
			
			# This ensures we yield at least once every iteration of the loop and allow other fibers to execute.
			task.yield
		else
			break
		end
	end
end