Sha256: e7d07680d2a8070d19e83c89f9130c8b9bc6da625d566083d1be2407c3ea0e57
Contents?: true
Size: 464 Bytes
Versions: 27
Compression:
Stored size: 464 Bytes
Contents
# -*- encoding: binary -*-
# :enddoc:
class Rainbows::Fiber::Coolio::Server < Coolio::IOWatcher
def to_io
@io
end
def initialize(io)
@io = io
super(self, :r)
end
def close
detach if attached?
@io.close
end
def on_readable
return if Rainbows.cur >= MAX
c = @io.kgio_tryaccept and Fiber.new { process(c) }.resume
end
def process(io)
Rainbows.cur += 1
io.process_loop
ensure
Rainbows.cur -= 1
end
end
Version data entries
27 entries across 27 versions & 1 rubygems