Extract the method to handle headers.

Signed-off-by: François de Metz <francois@stormz.me>

lib/em-eventsource.rb

@@ -111,22 +111,9 @@ def close
 
     def listen
       @conn, @req = prepare_request
+      @req.headers(&method(:handle_headers))
       @req.errback(&method(:handle_reconnect))
       @req.callback(&method(:handle_reconnect))
-      @req.headers do |headers|
-        if headers.status != 200
-          close
-          @errors.each { |error| error.call("Unexpected response status #{headers.status}") }
-          next
-        end
-        if /^text\/event-stream/.match headers['CONTENT_TYPE']
-          @ready_state = OPEN
-          @opens.each { |open| open.call }
-        else
-          close
-          @errors.each { |error| error.call("The content-type '#{headers['CONTENT_TYPE']}' is not text/event-stream") }
-        end
-      end
       buffer = ""
       @req.stream do |chunk|
         buffer += chunk
@@ -147,6 +134,21 @@ def handle_reconnect(*args)
       end
     end
 
+    def handle_headers(headers)
+      if headers.status != 200
+        close
+        @errors.each { |error| error.call("Unexpected response status #{headers.status}") }
+        return
+      end
+      if /^text\/event-stream/.match headers['CONTENT_TYPE']
+        @ready_state = OPEN
+        @opens.each { |open| open.call }
+      else
+        close
+        @errors.each { |error| error.call("The content-type '#{headers['CONTENT_TYPE']}' is not text/event-stream") }
+      end
+    end
+
     def handle_stream(stream)
       data = ""
       name = nil