diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java index aa5f855290..9482a5f09f 100644 --- a/rxjava-core/src/main/java/rx/Observable.java +++ b/rxjava-core/src/main/java/rx/Observable.java @@ -2203,6 +2203,7 @@ public Observable throttleLast(long intervalDuration, TimeUnit unit, Schedule * @return an Observable that emits timestamped items from the source * Observable * @see RxJava Wiki: timestamp() + * @see MSDN: Observable.Timestamp */ public Observable> timestamp() { return create(OperationTimestamp.timestamp(this)); @@ -2211,11 +2212,14 @@ public Observable> timestamp() { /** * Wraps each item emitted by a source Observable in a {@link Timestamped} * object with timestamps provided by the given Scheduler. + *

+ * * * @param scheduler the {@link Scheduler} to use as a time source. * @return an Observable that emits timestamped items from the source * Observable with timestamps provided by the given Scheduler - * @see MSDN: Observable.Timestamp + * @see RxJava Wiki: timestamp() + * @see MSDN: Observable.Timestamp */ public Observable> timestamp(Scheduler scheduler) { return create(OperationTimestamp.timestamp(this, scheduler)); @@ -5115,6 +5119,8 @@ public Observable> groupBy(final Func1 + * * * @param right the other Observable to correlate values of this observable to * @param leftDuration function that returns an Observable which indicates the duration of @@ -5126,6 +5132,7 @@ public Observable> groupBy(final Func1RxJava Wiiki: groupJoin * @see MSDN: Observable.GroupJoin */ public Observable groupJoin(Observable right, Func1> leftDuration, @@ -6165,42 +6172,56 @@ public Observable>> toMultimap(Func1 * * * @param other the other Observable that has to emit an element before this * Observable's elements are relayed - * @return an Observable that skips elements from the source Observable until the secondary - * observable emits an element. + * @return an Observable that skips elements from the source Observable + * until the secondary Observable emits an element. * @see RxJava Wiki: skipUntil() - * @see MSDN: Observable.SkipUntil + * @see MSDN: Observable.SkipUntil */ public Observable skipUntil(Observable other) { return create(new OperationSkipUntil(this, other)); } - + /** - * Groups the elements of an observable sequence according to a specified key selector function until the duration observable expires for the key. - * @param keySelector A function to extract the key for each element. - * @param durationSelector A function to signal the expiration of a group. - * @return A sequence of observable groups, each of which corresponds to a unique key value, containing all elements that share that same key value. - * - * @see MSDN: Observable.GroupByUntil + * Groups the items emitted by an Observable according to a specified key + * selector function until the duration Observable expires for the key. + *

+ * + * + * @param keySelector a function to extract the key for each item + * @param durationSelector a function to signal the expiration of a group + * @return a sequence of Observable groups, each of which corresponds to a + * unique key value, containing all items that share that same + * key value + * @see RxJava Wiki: groupByUntil() + * @see MSDN: Observable.GroupByUntil */ public Observable> groupByUntil(Func1 keySelector, Func1, ? extends Observable> durationSelector) { return groupByUntil(keySelector, Functions.identity(), durationSelector); } /** - * Groups the elements of an observable sequence according to a specified key and value selector function until the duration observable expires for the key. - * @param keySelector A function to extract the key for each element. - * @param valueSelector A function to map each source element to an element in an onbservable group. - * @param durationSelector A function to signal the expiration of a group. - * @return A sequence of observable groups, each of which corresponds to a unique key value, containing all elements that share that same key value. - * - * @see MSDN: Observable.GroupByUntil + * Groups the items emitted by an Observable according to specified key and + * value selector functions until the duration Observable expires for the + * key. + *

+ * + * + * @param keySelector a function to extract the key for each item + * @param valueSelector a function to map each source element to an item + * emitted by an Observable group + * @param durationSelector a function to signal the expiration of a group + * @return a sequence of Observable groups, each of which corresponds to a + * unique key value, containing all items that share that same key + * value + * @see RxJava Wiki: groupByUntil() + * @see MSDN: Observable.GroupByUntil */ public Observable> groupByUntil(Func1 keySelector, Func1 valueSelector, Func1, ? extends Observable> durationSelector) { return create(new OperationGroupByUntil(this, keySelector, valueSelector, durationSelector));