class ActiveSupport::Testing::Parallelization::Server
Public Class Methods
new()
click to toggle source
# File lib/active_support/testing/parallelization.rb, line 12 def initialize @queue = Queue.new end
Public Instance Methods
<<(o)
click to toggle source
# File lib/active_support/testing/parallelization.rb, line 24 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 29 def length @queue.length end
pop()
click to toggle source
# File lib/active_support/testing/parallelization.rb, line 33 def pop; @queue.pop; end
record(reporter, result)
click to toggle source
# File lib/active_support/testing/parallelization.rb, line 16 def record(reporter, result) raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown) reporter.synchronize do reporter.record(result) end end