module AsyncResponse::Workers::Sidekiq

Public Instance Methods

response_for(job_id, &block) click to toggle source
# File lib/async_response/workers/sidekiq.rb, line 6
def response_for(job_id, &block)
  job = AsyncResponse::Job.find(job_id)
  return unless job

  worker_response = WorkerResponse.new(job)
  data = block.call(worker_response)
  worker_response.finished!(data)

rescue StandardError => e
  job.error = e.message
  job.errored!
  raise e
end