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