diff options
author | Eric Wong <normalperson@yhbt.net> | 2010-12-03 01:12:08 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2010-12-03 01:12:08 +0000 |
commit | c096e735efea5050b0559748633403f0387ea3b3 (patch) | |
tree | d0dac89e2fd29069da04096bf7f70288c6377eb4 /lib/rainbows/rev/client.rb | |
parent | 64889d9136fa5466269232c26a2f235dd763d8f0 (diff) | |
download | rainbows-c096e735efea5050b0559748633403f0387ea3b3.tar.gz |
All synchronous models have this fixed in unicorn 3.0.1, so only Rev and EventMachine-based concurrency models require code changes.
Diffstat (limited to 'lib/rainbows/rev/client.rb')
-rw-r--r-- | lib/rainbows/rev/client.rb | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/lib/rainbows/rev/client.rb b/lib/rainbows/rev/client.rb index bc85fbd..296a33d 100644 --- a/lib/rainbows/rev/client.rb +++ b/lib/rainbows/rev/client.rb @@ -16,6 +16,10 @@ module Rainbows @deferred = nil end + def want_more + enable unless enabled? + end + def quit super close if @deferred.nil? && @_write_buffer.empty? @@ -143,13 +147,13 @@ module Rainbows when :close close if @_write_buffer.empty? when :headers - if @hp.parse - app_call - else + if @buf.empty? unless enabled? enable KATO[self] = Time.now end + else + on_read("") end end rescue => e |