class ActiveSupport::Testing::Parallelization::Server

Public Class Methods

new() click to toggle source
# File lib/active_support/testing/parallelization.rb, line 13
def initialize
  @queue = Queue.new
end

Public Instance Methods

<<(o) click to toggle source
# File lib/active_support/testing/parallelization.rb, line 25
def <<(o)
  o[2] = DRbObject.new(o[2]) if o
  @queue << o
end
length() click to toggle source
# File lib/active_support/testing/parallelization.rb, line 30
def length
  @queue.length
end
pop() click to toggle source
# File lib/active_support/testing/parallelization.rb, line 34
def pop; @queue.pop; end
record(reporter, result) click to toggle source
# File 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