Skip to content

Commit b8e59a8

Browse files
Merge pull request #1602 from abersnaze/consistent-retrywhen
Make retryWhen the same with the Scheduler as the retryWhen without the Scheduler
2 parents 83cc1c1 + 9043a4f commit b8e59a8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

rxjava-core/src/main/java/rx/Observable.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6667,7 +6667,7 @@ public final Observable<T> repeat(final long count, Scheduler scheduler) {
66676667
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
66686668
* @since 0.20
66696669
*/
6670-
public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<? extends Notification<?>>> notificationHandler, Scheduler scheduler) {
6670+
public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) {
66716671
return OnSubscribeRedo.repeat(this, notificationHandler, scheduler);
66726672
}
66736673

@@ -6692,7 +6692,7 @@ public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notific
66926692
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
66936693
* @since 0.20
66946694
*/
6695-
public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<? extends Notification<?>>> notificationHandler) {
6695+
public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) {
66966696
return OnSubscribeRedo.repeat(this, notificationHandler);
66976697
}
66986698

@@ -7435,7 +7435,7 @@ public final Observable<T> retryWhen(Func1<? super Observable<? extends Notifica
74357435
* @see <a href="https://github.com/Netflix/RxJava/wiki/Error-Handling-Operators#retrywhen">RxJava Wiki: retryWhen()</a>
74367436
* @since 0.20
74377437
*/
7438-
public final Observable<T> retryWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<? extends Notification<?>>> notificationHandler, Scheduler scheduler) {
7438+
public final Observable<T> retryWhen(Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) {
74397439
return OnSubscribeRedo.<T> retry(this, notificationHandler, scheduler);
74407440
}
74417441

0 commit comments

Comments
 (0)