module ActiveJob::TestHelper

Public Instance Methods

perform_enqueued_jobs(only: nil, except: nil, queue: nil) click to toggle source
Calls superclass method
# File lib/rails_6_polyfills/activejob/serializers.rb, line 198
def perform_enqueued_jobs(only: nil, except: nil, queue: nil)
  return flush_enqueued_jobs(only: only, except: except, queue: queue) unless block_given?

  super
end

Private Instance Methods

enqueued_jobs_with(only: nil, except: nil, queue: nil, &block) click to toggle source
# File lib/rails_6_polyfills/activejob/serializers.rb, line 228
def enqueued_jobs_with(only: nil, except: nil, queue: nil, &block)
  jobs_with(enqueued_jobs, only: only, except: except, queue: queue, &block)
end
flush_enqueued_jobs(only: nil, except: nil, queue: nil) click to toggle source
# File lib/rails_6_polyfills/activejob/serializers.rb, line 232
def flush_enqueued_jobs(only: nil, except: nil, queue: nil)
  enqueued_jobs_with(only: only, except: except, queue: queue) do |payload|
    instantiate_job(payload).perform_now
    queue_adapter.performed_jobs << payload
  end
end
jobs_with(jobs, only: nil, except: nil, queue: nil) { |job| ... } click to toggle source
# File lib/rails_6_polyfills/activejob/serializers.rb, line 206
def jobs_with(jobs, only: nil, except: nil, queue: nil)
  validate_option(only: only, except: except)

  jobs.count do |job|
    job_class = job.fetch(:job)

    if only
      next false unless filter_as_proc(only).call(job)
    elsif except
      next false if filter_as_proc(except).call(job)
    end

    if queue
      next false unless queue.to_s == job.fetch(:queue, job_class.queue_name)
    end

    yield job if block_given?

    true
  end
end