# File lib/core/container.rb, line 258 def initialize container, io, opts, server=false super io, opts[:handler] transport.set_server if server transport.apply opts connection.apply opts @work_queue = WorkQueue.new(container) connection.instance_variable_set(:@work_queue, @work_queue) end
# File lib/core/container.rb, line 269 def dispatch # Intercept dispatch to close work_queue super @work_queue.close if read_closed? && write_closed? end
# File lib/core/container.rb, line 266 def next_tick() earliest(super, @work_queue.next_tick); end
# File lib/core/container.rb, line 267 def process(now) @work_queue.process(now); super(); end