ActiveSupport::Testing::Parallelization::Server < Object

# File activesupport/lib/active_support/testing/parallelization.rb, line 13
        def initialize
          @queue = Queue.new
        end

# File activesupport/lib/active_support/testing/parallelization.rb, line 25
        def <<(o)
          o[2] = DRbObject.new(o[2]) if o
          @queue << o
        end

# File activesupport/lib/active_support/testing/parallelization.rb, line 30
        def length
          @queue.length
        end

# File activesupport/lib/active_support/testing/parallelization.rb, line 34
        def pop; @queue.pop; end

# File activesupport/lib/active_support/testing/parallelization.rb, line 17
        def record(reporter, result)
          raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown)

          reporter.synchronize do
            reporter.record(result)
          end
        end