Sha256: 77707206d497b02d31014b97ae1fe1559d66bf0ffa1c68316799850a8cd47269
Contents?: true
Size: 858 Bytes
Versions: 25
Compression:
Stored size: 858 Bytes
Contents
module Rasti
class App
class AsynchronicInteraction < Interaction
def self.asynchronic?
true
end
private
def job
@job ||= Asynchronic[context.fetch(:job_id)].job
end
def enqueue(interaction, params)
job.send :async, Job, queue: params.delete(:queue) || Asynchronic.default_queue,
alias: params.delete(:alias) || interaction,
dependency: params.delete(:dependency),
dependencies: params.delete(:dependencies),
interaction: interaction,
context: context,
params: params
end
def result_of(reference)
job.send :result, reference
end
end
end
end
Version data entries
25 entries across 25 versions & 1 rubygems