Class: Dipa::Processor::Base

Inherits:
Object
  • Object
show all
Includes:
Concerns::Coordinator, Concerns::Options, Concerns::Source, Concerns::State, Concerns::Wait
Defined in:
lib/dipa/processor/base.rb

Direct Known Subclasses

Each, Map

Constant Summary collapse

OVERRIDE_OPTIONS = 
{}.freeze

Constants included from Concerns::Wait

Concerns::Wait::SYNC_MODE_MAX_SLEEP_DURATION, Concerns::Wait::SYNC_MODE_SLEEP_DURATION_INCREASE_FACTOR, Concerns::Wait::SYNC_MODE_SLEEP_START_DURATION

Constants included from Concerns::Options

Concerns::Options::DEFAULT_ASYNC, Concerns::Options::DEFAULT_KEEP_DATA, Concerns::Options::DEFAULT_WANT_RESULT, Concerns::Options::OPTIONS_MAPPING

Instance Method Summary collapse

Instance Method Details

#with(processor_class, processor_method) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/dipa/processor/base.rb', line 14

def with(processor_class, processor_method)
  _check_state

  _prepare_coordinator(processor_class: processor_class.to_s,
                       processor_method: processor_method.to_s)

  _start_process

  _result_and_cleanup
ensure
  _reset_state
end