Sha256: 2ffb20cdff2660b4636b8592535091cd683bceaf237614fe9fb77809f693ed67
Contents?: true
Size: 728 Bytes
Versions: 12
Compression:
Stored size: 728 Bytes
Contents
# typed: false
require_relative '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
12 entries across 12 versions & 1 rubygems