@@ -1811,11 +1811,12 @@ 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.
1814
+ * Throttles by dropping all values that are followed by newer values before the timeout value expires. The timer reset on each `onNext` call.
1815
+ * <p>
1816
+ * NOTE: If the timeout is set higher than the rate of traffic then this will drop all data.
1815
1817
*
1816
1818
* @param timeout
1817
1819
* The time each value has to be 'the most recent' of the {@link Observable} to ensure that it's not dropped.
1818
- *
1819
1820
* @param unit
1820
1821
* The {@link TimeUnit} for the timeout.
1821
1822
*
@@ -1826,15 +1827,17 @@ public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit) {
1826
1827
}
1827
1828
1828
1829
/**
1829
- * Throttles the {@link Observable} by dropping values which are followed by newer values before the timer has expired.
1830
+ * Throttles by dropping all values that are followed by newer values before the timeout value expires. The timer reset on each `onNext` call.
1831
+ * <p>
1832
+ * NOTE: If the timeout is set higher than the rate of traffic then this will drop all data.
1830
1833
*
1831
1834
* @param timeout
1832
1835
* The time each value has to be 'the most recent' of the {@link Observable} to ensure that it's not dropped.
1833
1836
* @param unit
1834
- * The {@link TimeUnit} for the timeout.
1837
+ * The unit of time for the specified timeout.
1835
1838
* @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 .
1839
+ * The {@link Scheduler} to use internally to manage the timers which handle timeout for each event .
1840
+ * @return Observable which performs the throttle operation .
1838
1841
*/
1839
1842
public Observable <T > throttleWithTimeout (long timeout , TimeUnit unit , Scheduler scheduler ) {
1840
1843
return create (OperationThrottleWithTimeout .throttleWithTimeout (this , timeout , unit , scheduler ));
0 commit comments