Methods

Included Modules

  • DRb::DRbUndumped

Class Public methods

new()

Source: 

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

Instance Public methods

<<(o)

Source: 

# 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: 

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

pop()

Source: 

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

record(reporter, result)

Source: 

# 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