class ActiveSupport::Testing::Parallelization::Server

:nodoc:

def <<(o) 

def <<(o)
  o[2] = DRbObject.new(o[2]) if o
  @queue << o
end

def initialize 

def initialize
  @queue = Queue.new
end

def length 

def length
  @queue.length
end

def pop; @queue.pop; end 

def pop; @queue.pop; end

def record(reporter, result) 

def record(reporter, result)
  raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown)
  reporter.synchronize do
    reporter.record(result)
  end
end