make FetchEvents store last event of each stream

When testing with Publish rspec assertion, we should store what is
the last event of each stream we check.
Not what is the last event in the whole event store.

Author: pjurewicz

ruby_event_store-rspec/lib/ruby_event_store/rspec/fetch_events.rb

@@ -15,10 +15,6 @@ def in(event_store)
         @event_store = event_store
       end
 
-      def from_last
-        @start = call.last&.event_id
-      end
-
       def call
         raise MissingEventStore if event_store.nil?
         events = event_store.read

ruby_event_store-rspec/lib/ruby_event_store/rspec/publish.rb

@@ -7,6 +7,7 @@ def initialize(*expected, failure_message_formatter:)
         @expected = ExpectedCollection.new(expected)
         @failure_message_formatter = failure_message_formatter
         @fetch_events = FetchEvents.new
+        @start_for_stream = {}
       end
 
       def in(event_store)
@@ -45,10 +46,16 @@ def strict
       end
 
       def matches?(event_proc)
-        fetch_events.from_last
+        stream_names.each do |stream_name|
+          fetch_events.stream(stream_name)
+          @start_for_stream[stream_name] = fetch_events.call.last&.event_id
+        end
+
         event_proc.call
+
         stream_names.all? do |stream_name|
           fetch_events.stream(stream_name)
+          fetch_events.from(@start_for_stream.fetch(stream_name))
           @published_events = fetch_events.call.to_a
           @failed_on_stream = stream_name
           MatchEvents.new.call(expected, published_events)

ruby_event_store-rspec/spec/ruby_event_store/rspec/publish_spec.rb

@@ -246,6 +246,18 @@ def colorless_differ
           event_store.publish(BarEvent.new)
         end.to matcher(matchers.an_event(FooEvent), matchers.an_event(BarEvent)).strict.in(event_store)
       end
+
+      specify do
+        event_store.publish(FooEvent.new, stream_name: "Stream$1")
+        event_store.publish(FooEvent.new, stream_name: "Stream$2")
+        expect do
+          event_store.publish(BarEvent.new, stream_name: "Stream$1")
+          event_store.publish(BarEvent.new, stream_name: "Stream$3")
+        end.to matcher(matchers.an_event(BarEvent))
+                 .strict
+                 .in(event_store)
+                 .in_streams(%w[Stream$1 Stream$3])
+      end
     end
   end
 end