Sha256: a87ba471a1fbb2cbfa671e3b070b0ba622ff8c4bd14cbad937dd700c868c0aa5
Contents?: true
Size: 743 Bytes
Versions: 9
Compression:
Stored size: 743 Bytes
Contents
# frozen_string_literal: true
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
9 entries across 9 versions & 1 rubygems