Support 'Expect: 100-continue' header by deferring sending request body until "100 Continue" response

Author: CodeMonkeySteve

lib/em-http/client.rb

@@ -199,7 +199,7 @@ def send_request(head, body)
       @conn.send_data request_header
 
       @req_body = body || (@req.file && Pathname.new(@req.file))
-      send_request_body
+      send_request_body unless @req.headers['expect'] == '100-continue'
     end
 
     def on_body_data(data)
@@ -223,6 +223,10 @@ def on_decoded_body_data(data)
       end
     end
 
+    def request_body_pending?
+      !!@req_body
+    end
+
     def send_request_body
       return  if @req_body.nil?
 

lib/em-http/http_connection.rb

@@ -151,7 +151,11 @@ def peer
 
     def receive_data(data)
       begin
-        @p << data
+        if client.request_body_pending? && data.starts_with?('HTTP/1.1 100 Continue')
+          client.send_request_body
+        else
+          @p << data
+        end
       rescue HTTP::Parser::Error => e
         c = @clients.shift
         c.nil? ? unbind(e.message) : c.on_error(e.message)