Module: Datadog::Tracing::Contrib::ConcurrentRuby::PromisesFuturePatch

Defined in:
lib/datadog/tracing/contrib/concurrent_ruby/promises_future_patch.rb

Overview

This patches the Future - to wrap executor service using ContextCompositeExecutorService

Instance Method Summary collapse

Instance Method Details

#future_on(default_executor, *args, &task) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/datadog/tracing/contrib/concurrent_ruby/promises_future_patch.rb', line 11

def future_on(default_executor, *args, &task)
  unless default_executor.is_a?(ContextCompositeExecutorService)
    default_executor = ContextCompositeExecutorService.new(default_executor)
  end

  super(default_executor, *args, &task)
end