undo

Author: jaydeluca

instrumentation/rxjava/rxjava-2.0/library/src/main/java/io/opentelemetry/instrumentation/rxjava/v2_0/TracingAssembly.java

@@ -62,11 +62,6 @@ public final class TracingAssembly {
   private static BiFunction<? super Observable, ? super Observer, ? extends Observer>
       oldOnObservableSubscribe;
 
-  @SuppressWarnings("rawtypes")
-  @GuardedBy("TracingAssembly.class")
-  @Nullable
-  static volatile Function<? super Observable, ? extends Observable> oldOnObservableAssembly;
-
   @SuppressWarnings("rawtypes")
   @GuardedBy("TracingAssembly.class")
   @Nullable
@@ -123,8 +118,6 @@ public void enable() {
 
       enableObservable();
 
-      enableObservableAssembly();
-
       enableCompletable();
 
       enableSingle();
@@ -149,8 +142,6 @@ public void disable() {
 
       disableObservable();
 
-      disableObservableAssembly();
-
       disableCompletable();
 
       disableSingle();
@@ -228,18 +219,6 @@ private static void enableObservable() {
     }
   }
 
-  @GuardedBy("TracingAssembly.class")
-  @SuppressWarnings({"rawtypes", "unchecked"})
-  private static void enableObservableAssembly() {
-    if (TracingObserver.canEnable()) {
-      oldOnObservableAssembly = RxJavaPlugins.getOnObservableAssembly();
-      RxJavaPlugins.setOnObservableAssembly(
-          compose(
-              oldOnObservableAssembly,
-              observable -> new TracingObservable(observable, Context.current())));
-    }
-  }
-
   @GuardedBy("TracingAssembly.class")
   @SuppressWarnings({"rawtypes", "unchecked"})
   private static void enableSingle() {
@@ -295,12 +274,6 @@ private static void disableObservable() {
     oldOnObservableSubscribe = null;
   }
 
-  @GuardedBy("TracingAssembly.class")
-  private static void disableObservableAssembly() {
-    RxJavaPlugins.setOnObservableAssembly(oldOnObservableAssembly);
-    oldOnObservableAssembly = null;
-  }
-
   @GuardedBy("TracingAssembly.class")
   private static void disableCompletable() {
     RxJavaPlugins.setOnCompletableSubscribe(oldOnCompletableSubscribe);