Method: EmPipelines::AggregatedEventSource#initialize

Defined in:
lib/empipelines/aggregated_event_source.rb

#initialize(em, *event_sources) ⇒ AggregatedEventSource

Returns a new instance of AggregatedEventSource.



6
7
8
 
# File 'lib/empipelines/aggregated_event_source.rb', line 6

def initialize(em, *event_sources)
  @em, @sources = em, event_sources.flatten
end