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