Container driver applies options and adds container context to events
# File lib/core/container.rb, line 264 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 275 def dispatch # Intercept dispatch to close work_queue super @work_queue.send(:close) if read_closed? && write_closed? end
# File lib/core/container.rb, line 272 def next_tick() earliest(super, @work_queue.send(:next_tick)); end
# File lib/core/container.rb, line 273 def process(now) @work_queue.send(:process, now); super(); end