Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions src/main/java/io/reactivex/Flowable.java
Original file line number Diff line number Diff line change
Expand Up @@ -8598,7 +8598,7 @@ public final <R> Flowable<R> flatMapSingle(Function<? super T, ? extends SingleS
* {@link Consumer} to execute for each item.
* @return
* a Disposable that allows cancelling an asynchronous sequence
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null
* @throws RuntimeException
* if the Publisher calls {@code onError}
Expand Down Expand Up @@ -12070,7 +12070,7 @@ public final Disposable subscribe(Consumer<? super T> onNext) {
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the Publisher has finished sending them
* @see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null
*/
Expand Down Expand Up @@ -12101,7 +12101,7 @@ public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super T
* Publisher
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the Publisher has finished sending them
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null, or
* if {@code onComplete} is null
Expand Down Expand Up @@ -12137,7 +12137,7 @@ public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super T
* the {@code Consumer} that receives the upstream's Subscription
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the Publisher has finished sending them
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null, or
* if {@code onComplete} is null
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/Maybe.java
Original file line number Diff line number Diff line change
Expand Up @@ -3445,7 +3445,7 @@ public final Disposable subscribe(Consumer<? super T> onSuccess) {
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the Maybe has finished sending them
* @see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onSuccess} is null, or
* if {@code onError} is null
*/
Expand All @@ -3472,7 +3472,7 @@ public final Disposable subscribe(Consumer<? super T> onSuccess, Consumer<? supe
* Maybe
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the Maybe has finished sending them
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onSuccess} is null, or
* if {@code onError} is null, or
* if {@code onComplete} is null
Expand Down
8 changes: 4 additions & 4 deletions src/main/java/io/reactivex/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -7420,7 +7420,7 @@ public final <R> Observable<R> flatMapSingle(Function<? super T, ? extends Singl
* {@link Consumer} to execute for each item.
* @return
* a Disposable that allows cancelling an asynchronous sequence
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null
* @throws RuntimeException
* if the ObservableSource calls {@code onError}
Expand Down Expand Up @@ -10059,7 +10059,7 @@ public final Disposable subscribe(Consumer<? super T> onNext) {
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the ObservableSource has finished sending them
* @see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null
*/
Expand All @@ -10086,7 +10086,7 @@ public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super T
* ObservableSource
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the ObservableSource has finished sending them
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null, or
* if {@code onComplete} is null
Expand Down Expand Up @@ -10118,7 +10118,7 @@ public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super T
* the {@code Consumer} that receives the upstream's Disposable
* @return a {@link Disposable} reference with which the caller can stop receiving items before
* the ObservableSource has finished sending them
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onNext} is null, or
* if {@code onError} is null, or
* if {@code onComplete} is null
Expand Down
4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/Single.java
Original file line number Diff line number Diff line change
Expand Up @@ -2444,7 +2444,7 @@ public final Disposable subscribe() {
* (whichever is not null)
* @return a {@link Disposable} reference can request the {@link Single} stop work.
* @see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onCallback} is null
*/
@SchedulerSupport(SchedulerSupport.NONE)
Expand Down Expand Up @@ -2490,7 +2490,7 @@ public final Disposable subscribe(Consumer<? super T> onSuccess) {
* Single
* @return a {@link Disposable} reference can request the {@link Single} stop work.
* @see <a href="http://reactivex.io/documentation/operators/subscribe.html">ReactiveX operators documentation: Subscribe</a>
* @throws IllegalArgumentException
* @throws NullPointerException
* if {@code onSuccess} is null, or
* if {@code onError} is null
*/
Expand Down