Merge pull request #360 from RailsEventStore/aggregate_root_uses_batch_api

AggregatRoot loads events in batches

Author: mostlyobvious

aggregate_root/Makefile

@@ -1,7 +1,8 @@
 GEM_VERSION = $(shell cat ../RES_VERSION)
 GEM_NAME    = aggregate_root
 REQUIRE     = $(GEM_NAME)
-IGNORE      =
+IGNORE      = AggregateRoot\#events_enumerator
+
 SUBJECT     ?= AggregateRoot*
 
 install: ## Install gem dependencies

aggregate_root/lib/aggregate_root.rb

@@ -36,7 +36,7 @@ def apply(*events)
 
   def load(stream_name, event_store: default_event_store)
     @loaded_from_stream_name = stream_name
-    event_store.read.stream(stream_name).each.with_index do |event, index|
+    events_enumerator(event_store, stream_name).with_index do |event, index|
       apply(event)
       @version = index
     end
@@ -72,5 +72,9 @@ def default_event_store
     AggregateRoot.configuration.default_event_store
   end
 
+  def events_enumerator(event_store, stream_name)
+    event_store.read.in_batches.stream(stream_name).each
+  end
+
   attr_reader :loaded_from_stream_name
 end

aggregate_root/spec/aggregate_root_spec.rb

@@ -285,7 +285,6 @@
         end
       end.to raise_error(ArgumentError, "Anonymous class is missing name")
     end
-
   end
 
   describe '.include' do
@@ -294,5 +293,4 @@
       Order.include(AggregateRoot)
     end
   end
-
 end