Revert "Add RxJava 3 instrumentation (#11506)" (#11761)

Revert "Add RxJava 3 instrumentation (#11506)"

This reverts commit 35096e2.

Co-authored-by: bruce.bujon <bruce.bujon@datadoghq.com>

Author: PerfectSlayer

dd-java-agent/instrumentation/graal/graal-native-image-20.0/src/main/java/datadog/trace/instrumentation/graal/nativeimage/NativeImageGeneratorRunnerInstrumentation.java

@@ -157,7 +157,6 @@ public static void onEnter(@Advice.Argument(value = 0, readOnly = false) String[
               + "datadog.trace.instrumentation.reactivestreams.ReactiveStreamsAsyncResultExtension:build_time,"
               + "datadog.trace.instrumentation.reactor.core.ReactorAsyncResultExtension:build_time,"
               + "datadog.trace.instrumentation.rxjava2.RxJavaAsyncResultExtension:build_time,"
-              + "datadog.trace.instrumentation.rxjava3.RxJavaAsyncResultExtension:build_time,"
               + "datadog.trace.logging.ddlogger.DDLogger:build_time,"
               + "datadog.trace.logging.ddlogger.DDLoggerFactory:build_time,"
               + "datadog.trace.logging.ddlogger.DDLoggerFactory$HelperWrapper:build_time,"

dd-java-agent/instrumentation/java/java-concurrent/java-concurrent-1.8/src/main/java/datadog/trace/instrumentation/java/concurrent/AsyncPropagatingDisableInstrumentation.java

@@ -47,17 +47,6 @@ public AsyncPropagatingDisableInstrumentation() {
       namedOneOf("reactor.core.scheduler.SchedulerTask", "reactor.core.scheduler.WorkerTask");
   private static final ElementMatcher<TypeDescription> RXJAVA2_DISABLED_TYPE_INITIALIZERS =
       named("io.reactivex.internal.schedulers.AbstractDirectTask");
-
-  /**
-   * RxJava 3's AbstractDirectTask creates FINISHED/DISPOSED sentinel FutureTask instances in its
-   * static initializer. If that initializer runs while a trace is active (e.g. the first scheduled
-   * delay/timeout under a span), the executor instrumentation captures a continuation on those
-   * static singletons that is never cancelled, leaking the pending trace. Disable async propagation
-   * while the type initializer runs.
-   */
-  private static final ElementMatcher<TypeDescription> RXJAVA3_DISABLED_TYPE_INITIALIZERS =
-      named("io.reactivex.rxjava3.internal.schedulers.AbstractDirectTask");
-
   private static final ElementMatcher<TypeDescription> NETTY_GLOBAL_EVENT_EXECUTOR =
       namedOneOf(
           "io.netty.util.concurrent.GlobalEventExecutor",
@@ -101,7 +90,6 @@ public String[] knownMatchingTypes() {
       "org.apache.activemq.broker.TransactionBroker",
       "com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager",
       "io.reactivex.internal.schedulers.AbstractDirectTask",
-      "io.reactivex.rxjava3.internal.schedulers.AbstractDirectTask",
       "jdk.internal.net.http.HttpClientImpl",
       LETTUCE_HANDSHAKE_HANDLER,
       "io.netty.util.concurrent.GlobalEventExecutor",
@@ -122,7 +110,6 @@ public ElementMatcher<TypeDescription> hierarchyMatcher() {
         .or(GRPC_MANAGED_CHANNEL)
         .or(REACTOR_DISABLED_TYPE_INITIALIZERS)
         .or(RXJAVA2_DISABLED_TYPE_INITIALIZERS)
-        .or(RXJAVA3_DISABLED_TYPE_INITIALIZERS)
         .or(JAVA_HTTP_CLIENT);
   }
 
@@ -209,8 +196,6 @@ public void methodAdvice(MethodTransformer transformer) {
         isTypeInitializer().and(isDeclaredBy(REACTOR_DISABLED_TYPE_INITIALIZERS)), advice);
     transformer.applyAdvice(
         isTypeInitializer().and(isDeclaredBy(RXJAVA2_DISABLED_TYPE_INITIALIZERS)), advice);
-    transformer.applyAdvice(
-        isTypeInitializer().and(isDeclaredBy(RXJAVA3_DISABLED_TYPE_INITIALIZERS)), advice);
     transformer.applyAdvice(
         isTypeInitializer().and(isDeclaredBy(NETTY_GLOBAL_EVENT_EXECUTOR)), advice);
     transformer.applyAdvice(namedOneOf("sendAsync").and(isDeclaredBy(JAVA_HTTP_CLIENT)), advice);