Contents

module Semlogr
  module Sinks
    class Aggregate
      def initialize(sinks)
        @sinks = sinks
      end

      def emit(log_event)
        @sinks.each do |sink|
          sink.emit(log_event)
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
semlogr-0.3.0	lib/semlogr/sinks/aggregate.rb
semlogr-0.2.3	lib/semlogr/sinks/aggregate.rb
semlogr-0.2.2	lib/semlogr/sinks/aggregate.rb
semlogr-0.2.1	lib/semlogr/sinks/aggregate.rb
semlogr-0.2.0	lib/semlogr/sinks/aggregate.rb