diff options
Diffstat (limited to 'lib/rainbows/fiber/io.rb')
| -rw-r--r-- | lib/rainbows/fiber/io.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/rainbows/fiber/io.rb b/lib/rainbows/fiber/io.rb index bc6c0fe..5c51cb9 100644 --- a/lib/rainbows/fiber/io.rb +++ b/lib/rainbows/fiber/io.rb @@ -36,13 +36,13 @@ module Rainbows # used for reading headers (respecting keepalive_timeout) def read_timeout - expire = false + expire = nil begin to_io.read_nonblock(16384) rescue Errno::EAGAIN return if expire && expire < Time.now RD[self] = false - expire = Time.now + G.kato + expire ||= Time.now + G.kato ::Fiber.yield RD.delete(self) retry |