28 lines
492 B
Ruby
28 lines
492 B
Ruby
require 'abstract_unit'
|
|
require 'active_support/queueing'
|
|
|
|
class SynchronousQueueTest < ActiveSupport::TestCase
|
|
class Job
|
|
attr_reader :ran
|
|
def run; @ran = true end
|
|
end
|
|
|
|
class ExceptionRaisingJob
|
|
def run; raise end
|
|
end
|
|
|
|
def setup
|
|
@queue = ActiveSupport::SynchronousQueue.new
|
|
end
|
|
|
|
def test_runs_jobs_immediately
|
|
job = Job.new
|
|
@queue.push job
|
|
assert job.ran
|
|
|
|
assert_raises RuntimeError do
|
|
@queue.push ExceptionRaisingJob.new
|
|
end
|
|
end
|
|
end
|