diff options
Diffstat (limited to 'lib/rainbows/rev')
-rw-r--r-- | lib/rainbows/rev/client.rb | 1 | ||||
-rw-r--r-- | lib/rainbows/rev/deferred_response.rb | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/lib/rainbows/rev/client.rb b/lib/rainbows/rev/client.rb index 00df4d3..e0bccf0 100644 --- a/lib/rainbows/rev/client.rb +++ b/lib/rainbows/rev/client.rb @@ -74,6 +74,7 @@ class Rainbows::Rev::Client < Rev::IO end def next! + attached? or return @deferred = nil enable_write_watcher end diff --git a/lib/rainbows/rev/deferred_response.rb b/lib/rainbows/rev/deferred_response.rb index 146f505..4a92ee4 100644 --- a/lib/rainbows/rev/deferred_response.rb +++ b/lib/rainbows/rev/deferred_response.rb @@ -14,7 +14,7 @@ class Rainbows::Rev::DeferredResponse < Rev::IO end def on_close - @client.next! if @client.attached? # attached? is false if write fails @body.respond_to?(:close) and @body.close + @client.next! end end |