Module: OpenTelemetry::Adapters::ConcurrentRuby::Patches::Future

Defined in:
lib/opentelemetry/adapters/concurrent_ruby/patches/future.rb

Overview

Concurrent::Future patch for instrumentation

Class Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/opentelemetry/adapters/concurrent_ruby/patches/future.rb', line 15

def self.included(base)
  base.class_eval do
    alias_method :ns_initialize_without_otel, :ns_initialize
    remove_method(:ns_initialize)

    def ns_initialize(value, opts)
      ns_initialize_without_otel(value, opts)

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