Class: AggregateStreams::Projection

Inherits:
Object
  • Object
show all
Includes:
EntityProjection
Defined in:
lib/aggregate_streams/projection.rb

Instance Method Summary collapse

Instance Method Details

#apply(message_data) ⇒ Object



7
8
9
# File 'lib/aggregate_streams/projection.rb', line 7

def apply(message_data)
  aggregation.record_processed(message_data)
end