diff options
Diffstat (limited to 'lib/rainbows/client.rb')
-rw-r--r-- | lib/rainbows/client.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/rainbows/client.rb b/lib/rainbows/client.rb index 7387c44..4608f53 100644 --- a/lib/rainbows/client.rb +++ b/lib/rainbows/client.rb @@ -4,6 +4,8 @@ require "io/wait" # this class is used for most synchronous concurrency models class Rainbows::Client < Kgio::Socket + include Rainbows::ProcessClient + def read_expire Time.now + Rainbows.keepalive_timeout end @@ -16,7 +18,7 @@ class Rainbows::Client < Kgio::Socket def timed_read(buf) expire = nil begin - case rv = kgio_tryread(0x1000, buf) + case rv = kgio_tryread(HBUFSIZ, buf) when :wait_readable return if expire && expire < Time.now expire ||= read_expire @@ -26,6 +28,4 @@ class Rainbows::Client < Kgio::Socket end end while true end - - include Rainbows::ProcessClient end |