Module: Eventus::Consumer::InstanceMethods

Defined in:
lib/eventus/consumer.rb

Instance Method Summary collapse

Instance Method Details

#populate(events) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
 
# File 'lib/eventus/consumer.rb', line 11

def populate(events)
  if events.respond_to? :committed_events
    @stream = events
    events = events.committed_events
  end

  events.each do |event|
    apply_change event['name'], event['body'], false
  end
end