rev*: avoid hung connections when proxying HTTP/0.9

We don't send headers with HTTP/0.9 connections, so the IO write
watchers in Rev are never enabled if we're proxying IO objects
as the response body.

1 files changed, 4 insertions, 1 deletions

diff --git a/lib/rainbows/rev/client.rb b/lib/rainbows/rev/client.rb
index 2242c18..e2095bb 100644
--- a/lib/rainbows/rev/client.rb
+++ b/lib/rainbows/rev/client.rb
@@ -50,11 +50,14 @@ module Rainbows
       # here to prevent connections from being closed on us.
       def defer_body(io)
         @deferred_bodies << io
-        schedule_write
+        @_write_buffer.empty? ? on_write_complete : schedule_write
       end
 
       def next
         @deferred_bodies.shift
+        if :close == @state && @deferred_bodies.empty? && @_write_buffer.empty?
+          close
+        end
       end
 
       def timeout?