Sha256: a27c66b9aa82ab8de9141c4d3f46268547940012db5660a25ab31c2465eaa2dd
Contents?: true
Size: 697 Bytes
Versions: 14
Compression:
Stored size: 697 Bytes
Contents
module EventSourcery
module EventStore
module EachByRange
def each_by_range(from_event_id, to_event_id, event_types: nil)
caught_up = false
no_events_left = false
event_id = from_event_id
begin
events = get_next_from(event_id, event_types: event_types)
no_events_left = true if events.empty?
events.each do |event|
yield event
if event.id == to_event_id
caught_up = true
break
end
end
unless no_events_left
event_id = events.last.id + 1
end
end while !caught_up && !no_events_left
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems