@@ -1811,30 +1811,28 @@ public static Observable<Long> interval(long interval, TimeUnit unit, Scheduler
1811
1811
}
1812
1812
1813
1813
/**
1814
- * Throttles the {@link Observable} by dropping values which are followed by newer values before the timer has expired.
1815
- *
1816
- * @param timeout
1817
- * The time each value has to be 'the most recent' of the {@link Observable} to ensure that it's not dropped.
1814
+ * Throttles to last value in each window.
1818
1815
*
1816
+ * @param windowDuration
1817
+ * Duration of windows within with the first value will be chosen.
1819
1818
* @param unit
1820
- * The {@link TimeUnit} for the timeout.
1821
- *
1822
- * @return An {@link Observable} which filters out values which are too quickly followed up with newer values.
1819
+ * The unit of time for the specified timeout.
1820
+ * @return Observable which performs the throttle operation.
1823
1821
*/
1824
1822
public Observable <T > throttleLast (long timeout , TimeUnit unit ) {
1825
1823
return create (OperationThrottleLast .throttleLast (this , timeout , unit ));
1826
1824
}
1827
1825
1828
1826
/**
1829
- * Throttles the {@link Observable} by dropping values which are followed by newer values before the timer has expired .
1827
+ * Throttles to last value in each window .
1830
1828
*
1831
- * @param timeout
1832
- * The time each value has to be ' the most recent' of the {@link Observable} to ensure that it's not dropped .
1829
+ * @param windowDuration
1830
+ * Duration of windows within with the first value will be chosen .
1833
1831
* @param unit
1834
- * The {@link TimeUnit} for the timeout.
1832
+ * The unit of time for the specified timeout.
1835
1833
* @param scheduler
1836
- * The {@link Scheduler} to use when timing incoming values .
1837
- * @return An {@link Observable} which filters out values which are too quickly followed up with newer values .
1834
+ * The {@link Scheduler} to use internally to manage the timers which handle timeout for each event .
1835
+ * @return Observable which performs the throttle operation .
1838
1836
*/
1839
1837
public Observable <T > throttleLast (long timeout , TimeUnit unit , Scheduler scheduler ) {
1840
1838
return create (OperationThrottleLast .throttleLast (this , timeout , unit , scheduler ));
0 commit comments