Instrumentation for rxjava3.1.1

instrumentation/rxjava/rxjava-3-common/library/build.gradle.kts

@@ -0,0 +1,8 @@
+plugins {
+ id("otel.library-instrumentation")
+}
+
+dependencies {
+ library("io.reactivex.rxjava3:rxjava:3.0.12")
+ implementation(project(":instrumentation-api-annotation-support"))
+}

instrumentation/rxjava/rxjava-3.0/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingCompletableObserver.java → instrumentation/rxjava/rxjava-3-common/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingCompletableObserver.java

@@ -28,13 +28,13 @@
 import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.internal.disposables.DisposableHelper;
 
-class TracingCompletableObserver implements CompletableObserver, Disposable {
+public class TracingCompletableObserver implements CompletableObserver, Disposable {
 
  private final CompletableObserver actual;
  private final Context context;
  private Disposable disposable;
 
- TracingCompletableObserver(CompletableObserver actual, Context context) {
+ public TracingCompletableObserver(CompletableObserver actual, Context context) {
  this.actual = actual;
  this.context = context;
  }

instrumentation/rxjava/rxjava-3.0/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingMaybeObserver.java → instrumentation/rxjava/rxjava-3-common/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingMaybeObserver.java

@@ -28,13 +28,13 @@
 import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.internal.disposables.DisposableHelper;
 
-class TracingMaybeObserver<T> implements MaybeObserver<T>, Disposable {
+public class TracingMaybeObserver<T> implements MaybeObserver<T>, Disposable {
 
  private final MaybeObserver<T> actual;
  private final Context context;
  private Disposable disposable;
 
- TracingMaybeObserver(MaybeObserver<T> actual, Context context) {
+ public TracingMaybeObserver(MaybeObserver<T> actual, Context context) {
  this.actual = actual;
  this.context = context;
  }

instrumentation/rxjava/rxjava-3.0/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingSingleObserver.java → instrumentation/rxjava/rxjava-3-common/library/src/main/java/io/opentelemetry/instrumentation/rxjava3/TracingSingleObserver.java

@@ -28,13 +28,13 @@
 import io.reactivex.rxjava3.disposables.Disposable;
 import io.reactivex.rxjava3.internal.disposables.DisposableHelper;
 
-class TracingSingleObserver<T> implements SingleObserver<T>, Disposable {
+public class TracingSingleObserver<T> implements SingleObserver<T>, Disposable {
 
  private final SingleObserver<T> actual;
  private final Context context;
  private Disposable disposable;
 
- TracingSingleObserver(SingleObserver<T> actual, Context context) {
+ public TracingSingleObserver(SingleObserver<T> actual, Context context) {
  this.actual = actual;
  this.context = context;
  }

instrumentation/rxjava/rxjava-3.0/testing/build.gradle.kts → instrumentation/rxjava/rxjava-3-common/testing/build.gradle.kts

@@ -7,8 +7,8 @@ dependencies {
 
  api("io.reactivex.rxjava3:rxjava:3.0.12")
 
+ implementation("io.opentelemetry:opentelemetry-extension-annotations")
  implementation("com.google.guava:guava")
-
  implementation("org.codehaus.groovy:groovy-all")
  implementation("io.opentelemetry:opentelemetry-api")
  implementation("org.spockframework:spock-core")