Sha256: f291d3d21d8bdb456a366c9d56f9309ef2663303b3e5324d1970396e4ac0bec0
Contents?: true
Size: 678 Bytes
Versions: 65
Compression:
Stored size: 678 Bytes
Contents
require 'ddtrace/contrib/concurrent_ruby/context_composite_executor_service'
module Datadog
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
Version data entries
65 entries across 65 versions & 2 rubygems