Contents

require "forwardable"

module SandthornSequelProjection
  class EventHandlerCollection
    extend Forwardable
    def_delegators :handlers, :length, :each, :first

    attr_reader :handlers

    def initialize
      @handlers = Set.new
    end

    def define(handler_data)
      @handlers << EventHandler.new(handler_data)
    end

    def handle(projection, events)
      events.each do |event|
        handlers.each do |handler|
          handler.handle(projection, event)
        end
      end
    end

  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
sandthorn_sequel_projection-0.1.0	lib/sandthorn_sequel_projection/event_handler_collection.rb
sandthorn_sequel_projection-0.0.4	lib/sandthorn_sequel_projection/event_handler_collection.rb
sandthorn_sequel_projection-0.0.3	lib/sandthorn_sequel_projection/event_handler_collection.rb
sandthorn_sequel_projection-0.0.2	lib/sandthorn_sequel_projection/event_handler_collection.rb
sandthorn_sequel_projection-0.0.1	lib/sandthorn_sequel_projection/event_handler_collection.rb