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
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
3 4 5 |
# File 'lib/circuitry/processor.rb', line 3 def process(&_block) raise NotImplementedError, "#{self} must implement class method `process`" end |