Methods
#
L
N
P
R
Included Modules
Class Public methods
new()

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization.rb, line 13
def initialize
  @queue = Queue.new
end
Instance Public methods
<<(o)

Source: show | on GitHub 

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

Source: show | on GitHub 

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

Source: show | on GitHub 

# File activesupport/lib/active_support/testing/parallelization.rb, line 34
def pop; @queue.pop; end
record(reporter, result)

Source: show | on GitHub 

# 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