lib/reactor/event.rb in reactor-0.1.0 vs lib/reactor/event.rb in reactor-0.1.1

- old
+ new

@@ -38,9 +38,10 @@ remove_scheduled_job job if job delay.publish(name, data.except(:was)) if data[:at].future? end def self.process(name, data) + # fire database listeners Reactor::Subscriber.where(event: name.to_s).each do |subscriber| Reactor::Subscriber.delay.fire subscriber.id, data end #TODO: support more matching?