Class: EmPipelines::EventPipeline

Inherits:

Object

Object
EmPipelines::EventPipeline

show all

Defined in:: lib/empipelines/event_pipeline.rb

Instance Method Summary collapse

#initialize(source, pipeline, monitoring) ⇒ EventPipeline constructor

A new instance of EventPipeline.
#start! ⇒ Object

Constructor Details

#initialize(source, pipeline, monitoring) ⇒ `EventPipeline`

Returns a new instance of EventPipeline.

# File 'lib/empipelines/event_pipeline.rb', line 3

def initialize(source, pipeline, monitoring)
  @source, @pipeline, @monitoring = source, pipeline, monitoring

  @source.on_event do |event_data|
    @pipeline.notify(event_data)
  end
end

Instance Method Details

#start! ⇒ `Object`



11
12
13

# File 'lib/empipelines/event_pipeline.rb', line 11

def start!
  @source.start!
end