class AggregateStreams::Projection
Public Instance Methods
apply(message_data)
click to toggle source
# File lib/aggregate_streams/projection.rb, line 7 def apply(message_data) aggregation.record_processed(message_data) end