Contents

# typed: false

require 'datadog/tracing/contrib/concurrent_ruby/context_composite_executor_service'

module Datadog
  module Tracing
    module Contrib
      module ConcurrentRuby
        # This patches the Future - to wrap executor service using ContextCompositeExecutorService
        module FuturePatch
          def self.included(base)
            base.class_eval do
              alias_method :ns_initialize_without_datadog, :ns_initialize
              remove_method(:ns_initialize)

              def ns_initialize(value, opts)
                ns_initialize_without_datadog(value, opts)

                @executor = ContextCompositeExecutorService.new(@executor)
              end
            end
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ddtrace-1.2.0	lib/datadog/tracing/contrib/concurrent_ruby/future_patch.rb
ddtrace-1.1.0	lib/datadog/tracing/contrib/concurrent_ruby/future_patch.rb
ddtrace-1.0.0	lib/datadog/tracing/contrib/concurrent_ruby/future_patch.rb
ddtrace-1.0.0.beta2	lib/datadog/tracing/contrib/concurrent_ruby/future_patch.rb