Class: EmPipelines::EventSource

Inherits:

Object

Object
EmPipelines::EventSource

show all

Defined in:: lib/empipelines/event_source.rb

Direct Known Subclasses

AggregatedEventSource, AmqpEventSource, BatchEventSource, IOEventSource, PeriodicEventSource

Instance Method Summary collapse

Instance Method Details

#on_event(handler = nil, &block) ⇒ `Object`



3
4
5

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

def on_event(handler=nil, &block)
  add_handlers!(event_handler, (handler || block))
end

#on_finished(handler = nil, &block) ⇒ `Object`



7
8
9

# File 'lib/empipelines/event_source.rb', line 7

def on_finished(handler=nil, &block)
  add_handlers!(finished_handler, (handler || block))
end