Module: CDC::Concurrent::ProcessorExtensions

Defined in:

lib/cdc/concurrent/processor_extensions.rb

Overview

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

cdc-concurrent requires processors to explicitly opt in before they can be executed by Async-based runtime pools. The declaration is intentionally separate from ractor_safe! so processor authors can describe the execution model they support.

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary

• #concurrent_safe? ⇒ Boolean

  Reports whether this processor instance is safe for concurrent execution.

Instance Method Details

#concurrent_safe? ⇒ Boolean

Reports whether this processor instance is safe for concurrent execution.

Returns:

• (Boolean) —

  True when the processor class declared concurrent_safe!.

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

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