Sha256: 1a6bc0578d382c42c88df1893d8b64d88c50bec3facdeed6f2745499b057eefe
Contents?: true
Size: 638 Bytes
Versions: 26
Compression:
Stored size: 638 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 PromisesFuturePatch
def future_on(default_executor, *args, &task)
unless default_executor.is_a?(ContextCompositeExecutorService)
default_executor = ContextCompositeExecutorService.new(default_executor)
end
super(default_executor, *args, &task)
end
end
end
end
end
end
Version data entries
26 entries across 26 versions & 2 rubygems