@@ -5636,6 +5636,7 @@ public final Observable<T> repeat(final long count, Scheduler scheduler) {
5636
5636
* @return the source Observable modified with repeat logic
5637
5637
* @see <a href="https://github.com/Netflix/RxJava/wiki/Creating-Observables#wiki-repeat">RxJava Wiki: repeatWhen()</a>
5638
5638
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
5639
+ * @since 0.20
5639
5640
*/
5640
5641
public final Observable <T > repeatWhen (Func1 <? super Observable <? extends Notification <?>>, ? extends Observable <? extends Notification <?>>> notificationHandler , Scheduler scheduler ) {
5641
5642
return OnSubscribeRedo .repeat (this , notificationHandler , scheduler );
@@ -5648,12 +5649,15 @@ public final Observable<T> repeatWhen(Func1<? super Observable<? extends Notific
5648
5649
* or {@code onError} on the child subscription. Otherwise, this observable will resubscribe to the source observable.
5649
5650
* <p>
5650
5651
* <img width="640" height="430" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/repeatWhen.f.png" alt="">
5652
+ * <p>
5653
+ * {@code repeatWhen} operates by default on the {@code trampoline} {@link Scheduler}.
5651
5654
*
5652
5655
* @param notificationHandler
5653
5656
* recieves an Observable of notifications with which a user can complete or error, aborting the repeat.
5654
5657
* @return the source Observable modified with repeat logic
5655
5658
* @see <a href="https://github.com/Netflix/RxJava/wiki/Creating-Observables#wiki-repeat">RxJava Wiki: repeatWhen()</a>
5656
5659
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229428.aspx">MSDN: Observable.Repeat</a>
5660
+ * @since 0.20
5657
5661
*/
5658
5662
public final Observable <T > repeatWhen (Func1 <? super Observable <? extends Notification <?>>, ? extends Observable <? extends Notification <?>>> notificationHandler ) {
5659
5663
return OnSubscribeRedo .repeat (this , notificationHandler );
@@ -6301,6 +6305,7 @@ public final Observable<T> retry(Func2<Integer, Throwable, Boolean> predicate) {
6301
6305
* recieves an Observable of notifications with which a user can complete or error, aborting the retry.
6302
6306
* @return the source Observable modified with retry logic
6303
6307
* @see <a href="https://github.com/Netflix/RxJava/wiki/Error-Handling-Operators#wiki-retry">RxJava Wiki: retryWhen()</a>
6308
+ * @since 0.20
6304
6309
*/
6305
6310
public final Observable <T > retryWhen (Func1 <? super Observable <? extends Notification <?>>, ? extends Observable <?>> notificationHandler ) {
6306
6311
return OnSubscribeRedo .<T > retry (this , notificationHandler );
@@ -6319,6 +6324,7 @@ public final Observable<T> retryWhen(Func1<? super Observable<? extends Notifica
6319
6324
* recieves an Observable of notifications with which a user can complete or error, aborting the retry.
6320
6325
* @return the source Observable modified with retry logic
6321
6326
* @see <a href="https://github.com/Netflix/RxJava/wiki/Error-Handling-Operators#wiki-retry">RxJava Wiki: retryWhen()</a>
6327
+ * @since 0.20
6322
6328
*/
6323
6329
public final Observable <T > retryWhen (Func1 <? super Observable <? extends Notification <?>>, ? extends Observable <? extends Notification <?>>> notificationHandler , Scheduler scheduler ) {
6324
6330
return OnSubscribeRedo .<T > retry (this , notificationHandler , scheduler );
@@ -8971,7 +8977,7 @@ public final <T2, R> Observable<R> zip(Iterable<? extends T2> other, Func2<? sup
8971
8977
* and emits the results of {@code zipFunction} applied to these pairs
8972
8978
* @see <a href="https://github.com/Netflix/RxJava/wiki/Combining-Observables#zip">RxJava wiki: zip</a>
8973
8979
* @see <a href="http://msdn.microsoft.com/en-us/library/system.reactive.linq.observable.zip.aspx">MSDN: Observable.Zip</a>
8974
- * @deprecated Use zipWith instead. Changed to match naming convention of mergeWith, concatWith, etc
8980
+ * @deprecated use {@code zipWith} instead. Changed to match naming convention of {@code mergeWith}, {@code concatWith} , etc.
8975
8981
*/
8976
8982
@ Deprecated
8977
8983
public final <T2 , R > Observable <R > zip (Observable <? extends T2 > other , Func2 <? super T , ? super T2 , ? extends R > zipFunction ) {
@@ -8999,6 +9005,7 @@ public final <T2, R> Observable<R> zip(Observable<? extends T2> other, Func2<? s
8999
9005
* and emits the results of {@code zipFunction} applied to these pairs
9000
9006
* @see <a href="https://github.com/Netflix/RxJava/wiki/Combining-Observables#zip">RxJava wiki: zip</a>
9001
9007
* @see <a href="http://msdn.microsoft.com/en-us/library/system.reactive.linq.observable.zip.aspx">MSDN: Observable.Zip</a>
9008
+ * @since 0.20
9002
9009
*/
9003
9010
public final <T2 , R > Observable <R > zipWith (Observable <? extends T2 > other , Func2 <? super T , ? super T2 , ? extends R > zipFunction ) {
9004
9011
return zip (this , other , zipFunction );
0 commit comments