Contents

module Reactor
  class Subscriber < ActiveRecord::Base
    attr_accessor :event

    def event_name=(event)
      write_attribute :event_name, event.to_s
    end

    def fire(data)
      self.event = Reactor::Event.new(data)
      instance_exec &self.class.on_fire
      self
    end

    class << self
      def on_fire(&block)
        if block
          @fire_block = block
        end
        @fire_block
      end

      def fire(subscriber_id, data)
        Reactor::Subscriber.find(subscriber_id).fire data.with_indifferent_access
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
reactor-0.18.0	lib/reactor/models/subscriber.rb
reactor-0.17.0	lib/reactor/models/subscriber.rb
reactor-0.16.1	lib/reactor/models/subscriber.rb
reactor-0.16.0	lib/reactor/models/subscriber.rb
reactor-0.15.1	lib/reactor/models/subscriber.rb
reactor-0.15.0	lib/reactor/models/subscriber.rb
reactor-0.14.0	lib/reactor/models/subscriber.rb