class MingleEvents::Processors::Pipeline

Manages the passing of a stream of events through a sequence of processors

Public Class Methods

new(processors) click to toggle source
  # File lib/mingle_events/processors/pipeline.rb
7 def initialize(processors)
8   @processors = processors
9 end

Public Instance Methods

process_events(events) click to toggle source
   # File lib/mingle_events/processors/pipeline.rb
11 def process_events(events)
12   processed_events = events
13   @processors.each do |processor|
14     processed_events = processor.process_events(processed_events)
15   end
16   processed_events
17 end