class RailsEventStore::ActiveJobScheduler

Attributes

serializer[R]

Public Class Methods

new(serializer:) click to toggle source
# File lib/rails_event_store/active_job_scheduler.rb, line 7
def initialize(serializer:)
  @serializer = serializer
end

Public Instance Methods

call(klass, record) click to toggle source
# File lib/rails_event_store/active_job_scheduler.rb, line 11
def call(klass, record)
  klass.perform_later(record.serialize(serializer).to_h.transform_keys(&:to_s))
end
verify(subscriber) click to toggle source
# File lib/rails_event_store/active_job_scheduler.rb, line 15
def verify(subscriber)
  if Class === subscriber
    !!(subscriber < ActiveJob::Base)
  else
    subscriber.instance_of?(ActiveJob::ConfiguredJob)
  end
end