diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java index cf92fb12cd..33e451d3d1 100644 --- a/rxjava-core/src/main/java/rx/Observable.java +++ b/rxjava-core/src/main/java/rx/Observable.java @@ -2297,7 +2297,7 @@ public static Observable from(Future future, long timeout, T } /** - * Returns an Observable that emits a Boolean value that indicate + * Returns an Observable that emits a Boolean value that indicates * whether two sequences are equal by comparing the elements pairwise. *

* @@ -2305,8 +2305,8 @@ public static Observable from(Future future, long timeout, T * @param first the first Observable to compare * @param second the second Observable to compare * @param the type of items emitted by each Observable - * @return an Observable that emits a Boolean value that indicate - * whether two sequences are equal by comparing the elements pairwise. + * @return an Observable that emits a Boolean value that indicates + * whether two sequences are equal by comparing the elements pairwise * @see RxJava Wiki: sequenceEqual() */ public static Observable sequenceEqual(Observable first, Observable second) { @@ -2322,7 +2322,7 @@ public Boolean call(T first, T second) { } /** - * Returns an Observable that emits a Boolean value that indicate + * Returns an Observable that emits a Boolean value that indicates * whether two sequences are equal by comparing the elements pairwise * based on the results of a specified equality function. *

@@ -2333,8 +2333,8 @@ public Boolean call(T first, T second) { * @param equality a function used to compare items emitted by both * Observables * @param the type of items emitted by each Observable - * @return an Observable that emits a Boolean value that indicate - * whether two sequences are equal by comparing the elements pairwise. + * @return an Observable that emits a Boolean value that indicates + * whether two sequences are equal by comparing the elements pairwise * @see RxJava Wiki: sequenceEqual() */ public static Observable sequenceEqual(Observable first, Observable second, Func2 equality) { @@ -3311,7 +3311,7 @@ public Observable> window(long timespan, long timeshift, TimeUnit * invoke {@code onNext} as many times as the number of {@code onNext} * invokations of the source Observable that emits the fewest items. *

- * + * * * @param ws an Observable of source Observables * @param zipFunction a function that, when applied to an item emitted by @@ -3871,7 +3871,7 @@ public Observable reduce(Func2 accumulator) { * * @return an Observable that emits the number of counted elements of the * source Observable as its single item - * @see RxJava Wiki: count() + * @see RxJava Wiki: count() * @see MSDN: Observable.Count * @see #longCount() */ @@ -4475,12 +4475,14 @@ public Observable sample(long period, TimeUnit unit, Scheduler scheduler) { * Return an Observable that emits the results of sampling the items * emitted by this Observable when the sampler * Observable produces an item or completes. + *

+ * * * @param sampler the Observable to use for sampling this - * * @return an Observable that emits the results of sampling the items * emitted by this Observable when the sampler * Observable produces an item or completes. + * @see RxJava Wiki: sample() */ public Observable sample(Observable sampler) { return create(new OperationSample.SampleWithObservable(this, sampler)); @@ -5198,11 +5200,11 @@ public Observable last() { * Returns an Observable that counts the total number of items in the * source Observable as a 64 bit long. *

- * + * * * @return an Observable that emits the number of counted elements of the * source Observable as its single, 64 bit long item - * @see RxJava Wiki: count() + * @see RxJava Wiki: count() * @see MSDN: Observable.LongCount * @see #count() */