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.respond_to?(:concurrent_safe?) && self.class.concurrent_safe?
end