class Datadog::Tracing::Contrib::ConcurrentRuby::ContextCompositeExecutorService

Wraps existing executor to carry over trace context

def can_overflow?

Respect the {Concurrent::ExecutorService} interface 
def can_overflow?
  @composited_executor.can_overflow?
end

def datadog_configuration 

def datadog_configuration
  Datadog.configuration.tracing[:concurrent_ruby]
end

def initialize(composited_executor) 

def initialize(composited_executor)
  @composited_executor = composited_executor
end

def post(*args, &task)

captured to be propagated to the composited executor post method
post method runs the task within composited executor - in a different thread. The original arguments are 
def post(*args, &task)
  digest = Tracing.active_trace.to_digest
  executor = @composited_executor.is_a?(Symbol) ? Concurrent.executor(@composited_executor) : @composited_executor
  # Pass the original arguments to the composited executor, which
  # pushes them (possibly transformed) as block args
  executor.post(*args) do |*block_args|
    Tracing.continue_trace!(digest)
    # Pass the executor-provided block args as they should have been
    # originally passed without composition, see ChainPromise#on_resolvable
    yield(*block_args)
  end
end

def serialized?

Respect the {Concurrent::ExecutorService} interface 
def serialized?
  @composited_executor.serialized?
end