diff options
author | Eric Wong <normalperson@yhbt.net> | 2010-07-22 19:22:15 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2010-07-22 19:22:15 +0000 |
commit | 0fe78da5f4bb792719db4b8acafd728fbfce928e (patch) | |
tree | a6a963cb17b21a1409bd952b8996ee873e8bdf3a /lib | |
parent | b3a8d6aeccf2d865450b883d8b5cc166442f6205 (diff) | |
download | rainbows-0fe78da5f4bb792719db4b8acafd728fbfce928e.tar.gz |
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.
Diffstat (limited to 'lib')
-rw-r--r-- | lib/rainbows/rev/client.rb | 5 |
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? |