1 # -*- encoding: binary -*-
5 # this class is used for most synchronous concurrency models
6 class Rainbows::Client < Kgio::Socket
7 include Rainbows::ProcessClient
10 Time.now + Rainbows.keepalive_timeout
13 def kgio_wait_readable
14 wait Rainbows.keepalive_timeout
17 # used for reading headers (respecting keepalive_timeout)
21 case rv = kgio_tryread(HBUFSIZ, buf)
23 return if expire && expire < Time.now
24 expire ||= read_expire