Sha256: 6c9b1fc810c26ac20fffc981ab45c060026ae0c1cd164b2d9bc5ed5ed466070c
Contents?: true
Size: 478 Bytes
Versions: 24
Compression:
Stored size: 478 Bytes
Contents
# frozen_string_literal: true
require_relative 'context_composite_executor_service'
module Datadog
module Tracing
module Contrib
module ConcurrentRuby
# This patches the Async - to wrap executor service using ContextCompositeExecutorService
module AsyncPatch
def initialize(delegate)
super(delegate)
@executor = ContextCompositeExecutorService.new(@executor)
end
end
end
end
end
end
Version data entries
24 entries across 24 versions & 2 rubygems