diff --git a/src/main/java/io/reactivex/rxjava3/core/CompletableOnSubscribe.java b/src/main/java/io/reactivex/rxjava3/core/CompletableOnSubscribe.java index 0ac107e64b..e73fae2d5c 100644 --- a/src/main/java/io/reactivex/rxjava3/core/CompletableOnSubscribe.java +++ b/src/main/java/io/reactivex/rxjava3/core/CompletableOnSubscribe.java @@ -17,7 +17,7 @@ /** * A functional interface that has a {@code subscribe()} method that receives - * an instance of a {@link CompletableEmitter} instance that allows pushing + * a {@link CompletableEmitter} instance that allows pushing * an event in a cancellation-safe manner. */ @FunctionalInterface diff --git a/src/main/java/io/reactivex/rxjava3/core/FlowableOnSubscribe.java b/src/main/java/io/reactivex/rxjava3/core/FlowableOnSubscribe.java index c289a9e30b..6c5263b779 100644 --- a/src/main/java/io/reactivex/rxjava3/core/FlowableOnSubscribe.java +++ b/src/main/java/io/reactivex/rxjava3/core/FlowableOnSubscribe.java @@ -17,7 +17,7 @@ /** * A functional interface that has a {@code subscribe()} method that receives - * an instance of a {@link FlowableEmitter} instance that allows pushing + * a {@link FlowableEmitter} instance that allows pushing * events in a backpressure-safe and cancellation-safe manner. * * @param the value type pushed diff --git a/src/main/java/io/reactivex/rxjava3/core/MaybeOnSubscribe.java b/src/main/java/io/reactivex/rxjava3/core/MaybeOnSubscribe.java index 6c235bac84..67994d3d40 100644 --- a/src/main/java/io/reactivex/rxjava3/core/MaybeOnSubscribe.java +++ b/src/main/java/io/reactivex/rxjava3/core/MaybeOnSubscribe.java @@ -17,7 +17,7 @@ /** * A functional interface that has a {@code subscribe()} method that receives - * an instance of a {@link MaybeEmitter} instance that allows pushing + * a {@link MaybeEmitter} instance that allows pushing * an event in a cancellation-safe manner. * * @param the value type pushed diff --git a/src/main/java/io/reactivex/rxjava3/core/ObservableOnSubscribe.java b/src/main/java/io/reactivex/rxjava3/core/ObservableOnSubscribe.java index 587ab9372c..056441620a 100644 --- a/src/main/java/io/reactivex/rxjava3/core/ObservableOnSubscribe.java +++ b/src/main/java/io/reactivex/rxjava3/core/ObservableOnSubscribe.java @@ -17,7 +17,7 @@ /** * A functional interface that has a {@code subscribe()} method that receives - * an instance of an {@link ObservableEmitter} instance that allows pushing + * an {@link ObservableEmitter} instance that allows pushing * events in a cancellation-safe manner. * * @param the value type pushed diff --git a/src/main/java/io/reactivex/rxjava3/core/SingleOnSubscribe.java b/src/main/java/io/reactivex/rxjava3/core/SingleOnSubscribe.java index 9372cb5bdf..e8b9e89f8b 100644 --- a/src/main/java/io/reactivex/rxjava3/core/SingleOnSubscribe.java +++ b/src/main/java/io/reactivex/rxjava3/core/SingleOnSubscribe.java @@ -17,7 +17,7 @@ /** * A functional interface that has a {@code subscribe()} method that receives - * an instance of a {@link SingleEmitter} instance that allows pushing + * a {@link SingleEmitter} instance that allows pushing * an event in a cancellation-safe manner. * * @param the value type pushed