Class: Synapse::EventSourcing::CapturingEventStream

Inherits:
Domain::DomainEventStream show all
Extended by:
Forwardable
Defined in:
lib/synapse/event_sourcing/conflict_resolver.rb

Overview

Event stream decorator that captures any events that have been applied after the expected version of an aggregate

Instance Method Summary collapse

Methods inherited from Domain::DomainEventStream

#each, #end?, #peek, #to_a

Constructor Details

#initialize(delegate, unseen_events, expected_version) ⇒ undefined

Parameters:

  • delegate (DomainEventStream)
  • unseen_events (Array)
  • expected_version (Integer) 


62
63
64
65
66
 
# File 'lib/synapse/event_sourcing/conflict_resolver.rb', line 62

def initialize(delegate, unseen_events, expected_version)
  @delegate = delegate
  @unseen_events = unseen_events
  @expected_version = expected_version
end

Instance Method Details

#next_event ⇒ DomainEventMessage

Returns:

  • (DomainEventMessage) 


69
70
71
72
73
74
75
 
# File 'lib/synapse/event_sourcing/conflict_resolver.rb', line 69

def next_event
  @delegate.next_event.tap do |event|
    if @expected_version and event.sequence_number > @expected_version
      @unseen_events.push event
    end
  end
end