@@ -2297,16 +2297,16 @@ public static <T> Observable<T> from(Future<? extends T> future, long timeout, T
2297
2297
}
2298
2298
2299
2299
/**
2300
- * Returns an Observable that emits a Boolean value that indicate
2300
+ * Returns an Observable that emits a Boolean value that indicates
2301
2301
* whether two sequences are equal by comparing the elements pairwise.
2302
2302
* <p>
2303
2303
* <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/sequenceEqual.png">
2304
2304
*
2305
2305
* @param first the first Observable to compare
2306
2306
* @param second the second Observable to compare
2307
2307
* @param <T> the type of items emitted by each Observable
2308
- * @return an Observable that emits a Boolean value that indicate
2309
- * whether two sequences are equal by comparing the elements pairwise.
2308
+ * @return an Observable that emits a Boolean value that indicates
2309
+ * whether two sequences are equal by comparing the elements pairwise
2310
2310
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#sequenceequal">RxJava Wiki: sequenceEqual()</a>
2311
2311
*/
2312
2312
public static <T > Observable <Boolean > sequenceEqual (Observable <? extends T > first , Observable <? extends T > second ) {
@@ -2322,7 +2322,7 @@ public Boolean call(T first, T second) {
2322
2322
}
2323
2323
2324
2324
/**
2325
- * Returns an Observable that emits a Boolean value that indicate
2325
+ * Returns an Observable that emits a Boolean value that indicates
2326
2326
* whether two sequences are equal by comparing the elements pairwise
2327
2327
* based on the results of a specified equality function.
2328
2328
* <p>
@@ -2333,8 +2333,8 @@ public Boolean call(T first, T second) {
2333
2333
* @param equality a function used to compare items emitted by both
2334
2334
* Observables
2335
2335
* @param <T> the type of items emitted by each Observable
2336
- * @return an Observable that emits a Boolean value that indicate
2337
- * whether two sequences are equal by comparing the elements pairwise.
2336
+ * @return an Observable that emits a Boolean value that indicates
2337
+ * whether two sequences are equal by comparing the elements pairwise
2338
2338
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#sequenceequal">RxJava Wiki: sequenceEqual()</a>
2339
2339
*/
2340
2340
public static <T > Observable <Boolean > sequenceEqual (Observable <? extends T > first , Observable <? extends T > second , Func2 <? super T , ? super T , Boolean > equality ) {
@@ -3311,7 +3311,7 @@ public Observable<Observable<T>> window(long timespan, long timeshift, TimeUnit
3311
3311
* invoke {@code onNext} as many times as the number of {@code onNext}
3312
3312
* invokations of the source Observable that emits the fewest items.
3313
3313
* <p>
3314
- * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/zip.png">
3314
+ * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/zip.o. png">
3315
3315
*
3316
3316
* @param ws an Observable of source Observables
3317
3317
* @param zipFunction a function that, when applied to an item emitted by
@@ -3871,7 +3871,7 @@ public Observable<T> reduce(Func2<T, T, T> accumulator) {
3871
3871
*
3872
3872
* @return an Observable that emits the number of counted elements of the
3873
3873
* source Observable as its single item
3874
- * @see <a href="https://github.com/Netflix/RxJava/wiki/Mathematical-Operators#count">RxJava Wiki: count()</a>
3874
+ * @see <a href="https://github.com/Netflix/RxJava/wiki/Mathematical-Operators#count-and-longcount ">RxJava Wiki: count()</a>
3875
3875
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229470.aspx">MSDN: Observable.Count</a>
3876
3876
* @see #longCount()
3877
3877
*/
@@ -4475,12 +4475,14 @@ public Observable<T> sample(long period, TimeUnit unit, Scheduler scheduler) {
4475
4475
* Return an Observable that emits the results of sampling the items
4476
4476
* emitted by this Observable when the <code>sampler</code>
4477
4477
* Observable produces an item or completes.
4478
+ * <p>
4479
+ * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/sample.o.png">
4478
4480
*
4479
4481
* @param sampler the Observable to use for sampling this
4480
- *
4481
4482
* @return an Observable that emits the results of sampling the items
4482
4483
* emitted by this Observable when the <code>sampler</code>
4483
4484
* Observable produces an item or completes.
4485
+ * @see <a href="https://github.com/Netflix/RxJava/wiki/Filtering-Observables#sample-or-throttlelast">RxJava Wiki: sample()</a>
4484
4486
*/
4485
4487
public <U > Observable <T > sample (Observable <U > sampler ) {
4486
4488
return create (new OperationSample .SampleWithObservable <T , U >(this , sampler ));
@@ -5198,11 +5200,11 @@ public Observable<T> last() {
5198
5200
* Returns an Observable that counts the total number of items in the
5199
5201
* source Observable as a 64 bit long.
5200
5202
* <p>
5201
- * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/count .png">
5203
+ * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/longCount .png">
5202
5204
*
5203
5205
* @return an Observable that emits the number of counted elements of the
5204
5206
* source Observable as its single, 64 bit long item
5205
- * @see <a href="https://github.com/Netflix/RxJava/wiki/Mathematical-Operators#count">RxJava Wiki: count()</a>
5207
+ * @see <a href="https://github.com/Netflix/RxJava/wiki/Mathematical-Operators#count-and-longcount ">RxJava Wiki: count()</a>
5206
5208
* @see <a href="http://msdn.microsoft.com/en-us/library/hh229120.aspx">MSDN: Observable.LongCount</a>
5207
5209
* @see #count()
5208
5210
*/
0 commit comments