Module: CDC::Concurrent::ProcessorExtensions::ClassMethods

Defined in:
lib/cdc/concurrent/processor_extensions.rb

Overview

Class methods added to CDC::Core::Processor.

Instance Method Summary collapse

Instance Method Details

#concurrent_safe! ⇒ Object

Declare this processor safe for concurrent execution.



11
12
13
 
# File 'lib/cdc/concurrent/processor_extensions.rb', line 11

def concurrent_safe!
  @concurrent_safe = true
end

#concurrent_safe? ⇒ Boolean

Returns whether instances are concurrent-safe.

Returns:

  • (Boolean) —

    whether instances are concurrent-safe.



16
17
18
 
# File 'lib/cdc/concurrent/processor_extensions.rb', line 16

def concurrent_safe?
  @concurrent_safe == true
end