diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java index 5d98df26b9..04fa8e5132 100644 --- a/rxjava-core/src/main/java/rx/Observable.java +++ b/rxjava-core/src/main/java/rx/Observable.java @@ -2447,7 +2447,7 @@ public static Observable from(Future future, long timeout, T * @param the type of items emitted by each Observable * @return an Observable that emits a Boolean value that indicates whether * two sequences are equal by comparing the elements pairwise - * @see RxJava Wiki: sequenceEqual() + * @see RxJava Wiki: sequenceEqual() */ public static Observable sequenceEqual(Observable first, Observable second) { return sequenceEqual(first, second, new Func2() { @@ -2476,7 +2476,7 @@ public Boolean call(T first, T second) { * @param the type of items emitted by each Observable * @return an Observable that emits a Boolean value that indicates whether * two sequences are equal by comparing the elements pairwise - * @see RxJava Wiki: sequenceEqual() + * @see RxJava Wiki: sequenceEqual() */ public static Observable sequenceEqual(Observable first, Observable second, Func2 equality) { return OperationSequenceEqual.sequenceEqual(first, second, equality); @@ -3652,7 +3652,7 @@ public Observable elementAtOrDefault(int index, T defaultValue) { * @param predicate the condition to test every item emitted by the source * Observable * @return a subscription function for creating the target Observable - * @see RxJava Wiki: exists() + * @see RxJava Wiki: exists() * @see MSDN: Observable.Any Note: the description in this page was wrong at the time of this writing. */ public Observable exists(Func1 predicate) { @@ -3670,7 +3670,7 @@ public Observable exists(Func1 predicate) { * @return an Observable that emits true if the specified item * is emitted by the source Observable, or false if the * source Observable completes without emitting that item - * @see RxJava Wiki: contains() + * @see RxJava Wiki: contains() * @see MSDN: Observable.Contains */ public Observable contains(final T element) { @@ -5069,7 +5069,7 @@ public Observable scan(R initialValue, Func2 accumulator * @return an Observable that emits true if all items emitted * by the source Observable satisfy the predicate; otherwise, * false - * @see RxJava Wiki: all() + * @see RxJava Wiki: all() */ public Observable all(Func1 predicate) { return create(OperationAll.all(this, predicate)); @@ -5172,7 +5172,7 @@ public Observable firstOrDefault(Func1 predicate, T defau * @return an Observable that emits either the specified default item if the * source Observable emits no items, or the items emitted by the * source Observable - * @see RxJava Wiki: defaultIfEmpty() + * @see RxJava Wiki: defaultIfEmpty() * @see MSDN: Observable.DefaultIfEmpty */ public Observable defaultIfEmpty(T defaultValue) { @@ -5212,7 +5212,7 @@ public Observable take(final int num) { * @return an Observable that emits the items from the source Observable so * long as each item satisfies the condition defined by * predicate - * @see RxJava Wiki: takeWhile() + * @see RxJava Wiki: takeWhile() */ public Observable takeWhile(final Func1 predicate) { return create(OperationTakeWhile.takeWhile(this, predicate)); @@ -5232,7 +5232,7 @@ public Observable takeWhile(final Func1 predicate) { * @return an Observable that emits items from the source Observable so long * as the predicate continues to return true for each * item, then completes - * @see RxJava Wiki: takeWhileWithIndex() + * @see RxJava Wiki: takeWhileWithIndex() */ public Observable takeWhileWithIndex(final Func2 predicate) { return create(OperationTakeWhile.takeWhileWithIndex(this, predicate)); @@ -5301,7 +5301,7 @@ public Observable takeLast(final int count) { * @param the type of items emitted by other * @return an Observable that emits the items of the source Observable until * such time as other emits its first item - * @see RxJava Wiki: takeUntil() + * @see RxJava Wiki: takeUntil() */ public Observable takeUntil(Observable other) { return OperationTakeUntil.takeUntil(this, other); @@ -5320,7 +5320,7 @@ public Observable takeUntil(Observable other) { * as a second parameter. * @return an Observable that emits all items from the source Observable as * soon as the condition becomes false - * @see RxJava Wiki: skipWhileWithIndex() + * @see RxJava Wiki: skipWhileWithIndex() * @see MSDN: Observable.SkipWhile */ public Observable skipWhileWithIndex(Func2 predicate) { @@ -5338,7 +5338,7 @@ public Observable skipWhileWithIndex(Func2 predi * Observable for a condition * @return an Observable that emits all items from the source Observable as * soon as the condition becomes false - * @see RxJava Wiki: skipWhile() + * @see RxJava Wiki: skipWhile() * @see MSDN: Observable.SkipWhile */ public Observable skipWhile(Func1 predicate) { @@ -5719,7 +5719,7 @@ public Observable groupJoin(Observable right, Func1 * * @return an Observable that emits a Boolean - * @see RxJava Wiki: isEmpty() + * @see RxJava Wiki: isEmpty() * @see MSDN: Observable.Any */ public Observable isEmpty() { @@ -5964,7 +5964,7 @@ public static Observable using(Func0RxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2) { @@ -5981,7 +5981,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3) { @@ -5999,7 +5999,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4) { @@ -6018,7 +6018,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4, Observable o5) { @@ -6038,7 +6038,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4, Observable o5, Observable o6) { @@ -6059,7 +6059,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4, Observable o5, Observable o6, Observable o7) { @@ -6081,7 +6081,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4, Observable o5, Observable o6, Observable o7, Observable o8) { @@ -6104,7 +6104,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Observable o1, Observable o2, Observable o3, Observable o4, Observable o5, Observable o6, Observable o7, Observable o8, Observable o9) { @@ -6119,7 +6119,7 @@ public static Observable amb(Observable o1, ObservableRxJava Wiki: amb() + * @see RxJava Wiki: amb() * @see MSDN: Observable.Amb */ public static Observable amb(Iterable> sources) {