Module: Circuitry::Processor

Included in:
Circuitry::Processors::Batcher, Circuitry::Processors::Forker, Circuitry::Processors::Threader
Defined in:
lib/circuitry/processor.rb

Instance Method Summary collapse

Instance Method Details

#flush ⇒ Object

Raises:

  • (NotImplementedError) 


7
8
9
 
# File 'lib/circuitry/processor.rb', line 7

def flush
  raise NotImplementedError, "#{self} must implement class method `flush`"
end

#on_exit ⇒ Object 



11
12
13
 
# File 'lib/circuitry/processor.rb', line 11

def on_exit
  Circuitry.subscriber_config.on_async_exit
end

#process(&_block) ⇒ Object

Raises:

  • (NotImplementedError) 


3
4
5
 
# File 'lib/circuitry/processor.rb', line 3

def process(&_block)
  raise NotImplementedError, "#{self} must implement class method `process`"
end