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