Sha256: a871e755f4892120fcacd14cc48bfb98609106ac7b1e06c8dc814a7cfacc2c45
Contents?: true
Size: 693 Bytes
Versions: 5
Compression:
Stored size: 693 Bytes
Contents
# typed: false
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
5 entries across 5 versions & 1 rubygems