document set_event_handler

Author: igrigorik

lib/goliath/api.rb

@@ -259,16 +259,6 @@ def streaming_response(status_code = 200, headers ={})
 [status_code,headers,Goliath::Response::STREAMING]
 end
 
-defset_event_handler!(env)
-ifself.class.maps?
-response=self.class.router.recognize(env)
-ifresponse=self.class.router.recognize(env)andresponse.respond_to?(:path)andresponse.path.route.api_class
-env.event_handler=response.path.route.api_class.new
-end
-end
-env.event_handler ||= self
-end
-
 # Helper method for chunked transfer streaming response apis
 #
 # Chunked transfer streaming is transparent to all clients (it's just as
@@ -288,5 +278,20 @@ def set_event_handler!(env)
 defchunked_streaming_response(status_code=200,headers={})
 streaming_response(status_code,headers.merge(Goliath::Response::CHUNKED_STREAM_HEADERS))
 end
+
+# Helper method to initialize the approriate API handler
+#
+# Called by the parser once headers are available to detect
+# which API class should be handling the incoming request
+defset_event_handler!(env)
+ifself.class.maps?
+response=self.class.router.recognize(env)
+ifresponse=self.class.router.recognize(env)andresponse.respond_to?(:path)andresponse.path.route.api_class
+env.event_handler=response.path.route.api_class.new
+end
+end
+env.event_handler ||= self
+end
+
 end
 end

lib/goliath/connection.rb

@@ -34,6 +34,7 @@ def post_init
 r=Goliath::Request.new(@app,self,env)
 r.parse_header(h,@parser)do
 @api.set_event_handler!(env)
+
 env[ASYNC_HEADERS]=env.event_handler.method(:on_headers)ifenv.event_handler.respond_to?:on_headers
 env[ASYNC_BODY]=env.event_handler.method(:on_body)ifenv.event_handler.respond_to?:on_body
 env[ASYNC_CLOSE]=env.event_handler.method(:on_close)ifenv.event_handler.respond_to?:on_close