File tree Expand file tree Collapse file tree 2 files changed +25
-4
lines changed Expand file tree Collapse file tree 2 files changed +25
-4
lines changed Original file line number Diff line number Diff line change 44require 'aggregate_root/default_apply_strategy'
55
66module AggregateRoot
7- def apply ( event )
8- apply_strategy . ( self , event )
9- unpublished_events << event
7+ def apply ( *events )
8+ events . each do |event |
9+ apply_strategy . ( self , event )
10+ unpublished_events << event
11+ end
1012 end
1113
1214 def load ( stream_name , event_store : default_event_store )
Original file line number Diff line number Diff line change 133133 order . apply ( order_created )
134134 expect ( order . status ) . to eq :created
135135 end
136- end
136+
137+ it "should return applied events" do
138+ order = Order . new
139+ created = Orders ::Events ::OrderCreated . new
140+ expired = Orders ::Events ::OrderExpired . new
141+
142+ applied = order . apply ( created , expired )
143+ expect ( applied ) . to eq ( [ created , expired ] )
144+ end
145+
146+ it "should return only applied events" do
147+ order = Order . new
148+ created = Orders ::Events ::OrderCreated . new
149+ order . apply ( created )
150+
151+ expired = Orders ::Events ::OrderExpired . new
152+ applied = order . apply ( expired )
153+ expect ( applied ) . to eq ( [ expired ] )
154+ end
155+ end
You can’t perform that action at this time.
0 commit comments