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