Skip to content

Commit 7aa0b34

Browse files
authored
2.x: fixes, cleanups, renames (#4421)
* 2.x: fixes, cleanups, renames * Rename a few more parameters
1 parent 35c8da6 commit 7aa0b34

File tree

111 files changed

+1778
-1855
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

111 files changed

+1778
-1855
lines changed

src/main/java/io/reactivex/Completable.java

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -577,7 +577,7 @@ public static Completable never() {
577577
}
578578

579579
/**
580-
* Returns a Completable instance that fires its onComplete event after the given delay ellapsed.
580+
* Returns a Completable instance that fires its onComplete event after the given delay elapsed.
581581
* <dl>
582582
* <dt><b>Scheduler:</b></dt>
583583
* <dd>{@code timer} does operate by default on the {@code computation} {@link Scheduler}.</dd>
@@ -592,7 +592,7 @@ public static Completable timer(long delay, TimeUnit unit) {
592592
}
593593

594594
/**
595-
* Returns a Completable instance that fires its onComplete event after the given delay ellapsed
595+
* Returns a Completable instance that fires its onComplete event after the given delay elapsed
596596
* by using the supplied scheduler.
597597
* <dl>
598598
* <dt><b>Scheduler:</b></dt>
@@ -815,7 +815,7 @@ public final void blockingAwait() {
815815
* @param timeout the timeout value
816816
* @param unit the timeout unit
817817
* @return true if the this Completable instance completed normally within the time limit,
818-
* false if the timeout ellapsed before this Completable terminated.
818+
* false if the timeout elapsed before this Completable terminated.
819819
* @throws RuntimeException wrapping an InterruptedException if the current thread is interrupted
820820
*/
821821
@SchedulerSupport(SchedulerSupport.NONE)
@@ -840,12 +840,12 @@ public final Throwable blockingGet() {
840840

841841
/**
842842
* Subscribes to this Completable instance and blocks until it terminates or the specified timeout
843-
* ellapses, then returns null for normal termination or the emitted exception if any.
843+
* elapses, then returns null for normal termination or the emitted exception if any.
844844
* @param timeout the timeout value
845845
* @param unit the time unit
846846
* @return the throwable if this terminated with an error, null otherwise
847847
* @throws RuntimeException that wraps an InterruptedException if the wait is interrupted or
848-
* TimeoutException if the specified timeout ellapsed before it
848+
* TimeoutException if the specified timeout elapsed before it
849849
*/
850850
@SchedulerSupport(SchedulerSupport.NONE)
851851
public final Throwable blockingGet(long timeout, TimeUnit unit) {
@@ -957,7 +957,7 @@ public final Completable doOnComplete(Action onComplete) {
957957
}
958958

959959
/**
960-
* Returns a Completable which calls the giveon onDispose callback if the child subscriber cancels
960+
* Returns a Completable which calls the given onDispose callback if the child subscriber cancels
961961
* the subscription.
962962
* <dl>
963963
* <dt><b>Scheduler:</b></dt>
@@ -1069,9 +1069,13 @@ public final Completable doOnTerminate(final Action onTerminate) {
10691069
*/
10701070
@SchedulerSupport(SchedulerSupport.NONE)
10711071
public final Completable doAfterTerminate(final Action onAfterTerminate) {
1072-
return doOnLifecycle(Functions.emptyConsumer(), Functions.emptyConsumer(),
1073-
onAfterTerminate, Functions.EMPTY_ACTION,
1074-
Functions.EMPTY_ACTION, Functions.EMPTY_ACTION);
1072+
return doOnLifecycle(
1073+
Functions.emptyConsumer(),
1074+
Functions.emptyConsumer(),
1075+
Functions.EMPTY_ACTION,
1076+
Functions.EMPTY_ACTION,
1077+
onAfterTerminate,
1078+
Functions.EMPTY_ACTION);
10751079
}
10761080

10771081
/**
@@ -1618,7 +1622,7 @@ public final <T> Observable<T> toObservable() {
16181622
}
16191623

16201624
/**
1621-
* Convers this Completable into a Single which when this Completable completes normally,
1625+
* Converts this Completable into a Single which when this Completable completes normally,
16221626
* calls the given supplier and emits its returned value through onSuccess.
16231627
* <dl>
16241628
* <dt><b>Scheduler:</b></dt>
@@ -1636,7 +1640,7 @@ public final <T> Single<T> toSingle(final Callable<? extends T> completionValueS
16361640
}
16371641

16381642
/**
1639-
* Convers this Completable into a Single which when this Completable completes normally,
1643+
* Converts this Completable into a Single which when this Completable completes normally,
16401644
* emits the given value through onSuccess.
16411645
* <dl>
16421646
* <dt><b>Scheduler:</b></dt>

0 commit comments

Comments
 (0)