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