Module: CDC::Concurrent::ProcessorExtensions

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

Overview

Adds concurrent-safe declarations to CDC::Core::Processor subclasses.

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary collapse

#concurrent_safe? ⇒ Boolean
Whether this processor instance is concurrent-safe.

Instance Method Details

#concurrent_safe? ⇒ `Boolean`

Returns whether this processor instance is concurrent-safe.

Returns:

(Boolean) —
whether this processor instance is concurrent-safe.



22
23
24

# File 'lib/cdc/concurrent/processor_extensions.rb', line 22

def concurrent_safe?
  self.class.instance_variable_get(:@concurrent_safe) == true
end