Fix javadoc links

src/main/java/hu/akarnokd/rxjava3/consumers/CompletableConsumers.java

@@ -22,7 +22,7 @@
 import io.reactivex.rxjava3.internal.functions.*;
 
 /**
- * Utility methods for creating and using consumers {@link io.reactivex.Completable}s.
+ * Utility methods for creating and using consumers {@link io.reactivex.rxjava3.core.Completable}s.
  * @since 0.18.0
  */
 public final class CompletableConsumers {

src/main/java/hu/akarnokd/rxjava3/consumers/FlowableConsumers.java

@@ -22,7 +22,7 @@
 import io.reactivex.rxjava3.internal.functions.*;
 
 /**
- * Utility methods for creating and using consumers {@link io.reactivex.Flowable}s.
+ * Utility methods for creating and using consumers {@link io.reactivex.rxjava3.core.Flowable}s.
  * @since 0.18.0
  */
 public final class FlowableConsumers {

src/main/java/hu/akarnokd/rxjava3/consumers/MaybeConsumers.java

@@ -22,7 +22,7 @@
 import io.reactivex.rxjava3.internal.functions.*;
 
 /**
- * Utility methods for creating and using consumers {@link io.reactivex.Maybe}s.
+ * Utility methods for creating and using consumers {@link io.reactivex.rxjava3.core.Maybe}s.
  * @since 0.18.0
  */
 public final class MaybeConsumers {

src/main/java/hu/akarnokd/rxjava3/consumers/ObservableConsumers.java

@@ -22,7 +22,7 @@
 import io.reactivex.rxjava3.internal.functions.*;
 
 /**
- * Utility methods for creating and using consumers {@link io.reactivex.Observable}s.
+ * Utility methods for creating and using consumers {@link io.reactivex.rxjava3.core.Observable}s.
  * @since 0.18.0
  */
 public final class ObservableConsumers {

src/main/java/hu/akarnokd/rxjava3/consumers/SingleConsumers.java

@@ -22,7 +22,7 @@
 import io.reactivex.rxjava3.internal.functions.*;
 
 /**
- * Utility methods for creating and using consumers {@link io.reactivex.SingleObserver}s.
+ * Utility methods for creating and using consumers {@link io.reactivex.rxjava3.core.SingleObserver}s.
  * @since 0.18.0
  */
 public final class SingleConsumers {

src/main/java/hu/akarnokd/rxjava3/operators/FlowableTransformers.java

@@ -49,7 +49,7 @@ private FlowableTransformers() {
      * <ul>
      * <li>The operator starts with an open valve.</li>
      * <li>If the other Publisher completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * <li>The operator is a pass-through for backpressure and uses an internal unbounded buffer
      * of size {@link Flowable#bufferSize()} to hold onto values if the valve is closed.</li>
      * </ul>
@@ -73,7 +73,7 @@ public static <T> FlowableTransformer<T, T> valve(Publisher<Boolean> other) {
      * <p>Properties:
      * <ul>
      * <li>If the other Publisher completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * <li>The operator is a pass-through for backpressure and uses an internal unbounded buffer
      * of size {@link Flowable#bufferSize()} to hold onto values if the valve is closed.</li>
      * </ul>
@@ -99,7 +99,7 @@ public static <T> FlowableTransformer<T, T> valve(Publisher<Boolean> other, bool
      * <p>Properties:
      * <ul>
      * <li>If the other Publisher completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * </ul>
      * @param <T> the value type of the main source
      * @param other the other source
@@ -1229,7 +1229,7 @@ public static <T> FlowableTransformer<T, Long> indexOf(Predicate<? super T> pred
      * as an individual {@code Runnable} task. Each item received from the upstream will
      * also run on the given {@code Scheduler} as individual {@code Runnable} tasks which
      * should maximize the possibility of work interleaved on a threadpool-backed {@code Scheduler}
-     * such as {@link io.reactivex.schedulers.Schedulers#computation()}.
+     * such as {@link io.reactivex.rxjava3.schedulers.Schedulers#computation()}.
      * <dl>
      *  <dt><b>Backpressure:</b></dt>
      *  <dd>The operator requests one item at a time and requests the next item once the downstream
@@ -1257,7 +1257,7 @@ public static <T> FlowableTransformer<T, T> requestObserveOn(Scheduler scheduler
      *  <dt><b>Backpressure:</b></dt>
      *  <dd>The operator issues {@code request(1)} to its upstream periodically and expects the downstream
      *  to be ready to consume the items. If the downstream is not ready at that moment,
-     *  a {@link io.reactivex.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
+     *  a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
      *  and the flow is cancelled.</dd>
      *  <dt><b>Scheduler:</b></dt>
      *  <dd>You specify the {@link Scheduler} this operator should use for issuing each {@code request(1)} call.
@@ -1282,7 +1282,7 @@ public static <T> FlowableTransformer<T, T> requestSample(long period, TimeUnit
      *  <dt><b>Backpressure:</b></dt>
      *  <dd>The operator issues {@code request(1)} to its upstream after an initial delay, then periodically and expects the downstream
      *  to be ready to consume the items. If the downstream is not ready at that moment,
-     *  a {@link io.reactivex.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
+     *  a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
      *  and the flow is cancelled.</dd>
      *  <dt><b>Scheduler:</b></dt>
      *  <dd>You specify the {@link Scheduler} this operator should use for issuing each {@code request(1)} call.
@@ -1309,7 +1309,7 @@ public static <T> FlowableTransformer<T, T> requestSample(long initialDelay, lon
      *  <dt><b>Backpressure:</b></dt>
      *  <dd>The operator issues {@code request(1)} when the other {@code Publisher} signals an {@code onNext} and expects the downstream
      *  to be ready to consume the items. If the downstream is not ready at that moment,
-     *  a {@link io.reactivex.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
+     *  a {@link io.reactivex.rxjava3.exceptions.MissingBackpressureException MissingBackpressureException} is signalled
      *  and the flow is cancelled. The other {@code Publisher} is consumed in an unbounded manner.</dd>
      *  <dt><b>Scheduler:</b></dt>
      *  <dd>This operator doesn't run on any particular {@link Scheduler}.</dd>

src/main/java/hu/akarnokd/rxjava3/operators/ObservableTransformers.java

@@ -154,7 +154,7 @@ public static <T, R> ObservableTransformer<T, R> errorJump(ObservableTransformer
      * <ul>
      * <li>The operator starts with an open valve.</li>
      * <li>If the other ObservableSource completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * <li>The operator uses an internal unbounded buffer
      * of size {@link Flowable#bufferSize()} to hold onto values if the valve is closed.</li>
      * </ul>
@@ -177,7 +177,7 @@ public static <T> ObservableTransformer<T, T> valve(ObservableSource<Boolean> ot
      * <p>Properties:
      * <ul>
      * <li>If the other ObservableSource completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * <li>The operator uses an internal unbounded buffer
      * of size {@link Flowable#bufferSize()} to hold onto values if the valve is closed.</li>
      * </ul>
@@ -202,7 +202,7 @@ public static <T> ObservableTransformer<T, T> valve(ObservableSource<Boolean> ot
      * <p>Properties:
      * <ul>
      * <li>If the other ObservableSource completes, the sequence terminates with an {@code IllegalStateException}.</li>
-     * <li>The operator doesn't run on any particular {@link io.reactivex.Scheduler Scheduler}.</li>
+     * <li>The operator doesn't run on any particular {@link io.reactivex.rxjava3.core.Scheduler Scheduler}.</li>
      * </ul>
      * @param <T> the value type of the main source
      * @param other the other source

src/main/java/hu/akarnokd/rxjava3/subjects/Subjects.java

@@ -34,7 +34,7 @@ private Subjects() {
      * Wraps a Subject and makes sure if all observers dispose
      * their disposables, the upstream's Disposable gets disposed as well.
      * <p>
-     * This operator is similar to {@link io.reactivex.observables.ConnectableObservable#refCount()}
+     * This operator is similar to {@link io.reactivex.rxjava3.observables.ConnectableObservable#refCount()}
      * except the first Observer doesn't trigger any sort of connection; that happens
      * when the resulting Subject is subscribed to an Observable manually.
      * @param <T> the input and output value type