@@ -1815,6 +1815,8 @@ public static Observable<Long> interval(long interval, TimeUnit unit, Scheduler
1815
1815
* <p>
1816
1816
* NOTE: If events keep firing faster than the timeout then no data will be emitted.
1817
1817
* <p>
1818
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/debounce.png">
1819
+ * <p>
1818
1820
* Information on debounce vs throttle:
1819
1821
* <p>
1820
1822
* <ul>
@@ -1840,6 +1842,8 @@ public Observable<T> debounce(long timeout, TimeUnit unit) {
1840
1842
* <p>
1841
1843
* NOTE: If events keep firing faster than the timeout then no data will be emitted.
1842
1844
* <p>
1845
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/debounce.png">
1846
+ * <p>
1843
1847
* Information on debounce vs throttle:
1844
1848
* <p>
1845
1849
* <ul>
@@ -1866,6 +1870,8 @@ public Observable<T> debounce(long timeout, TimeUnit unit, Scheduler scheduler)
1866
1870
* <p>
1867
1871
* NOTE: If events keep firing faster than the timeout then no data will be emitted.
1868
1872
* <p>
1873
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleWithTimeout.png">
1874
+ * <p>
1869
1875
* Information on debounce vs throttle:
1870
1876
* <p>
1871
1877
* <ul>
@@ -1890,6 +1896,8 @@ public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit) {
1890
1896
* Debounces by dropping all values that are followed by newer values before the timeout value expires. The timer resets on each `onNext` call.
1891
1897
* <p>
1892
1898
* NOTE: If events keep firing faster than the timeout then no data will be emitted.
1899
+ * <p>
1900
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleWithTimeout.png">
1893
1901
*
1894
1902
* @param timeout
1895
1903
* The time each value has to be 'the most recent' of the {@link Observable} to ensure that it's not dropped.
@@ -1908,6 +1916,8 @@ public Observable<T> throttleWithTimeout(long timeout, TimeUnit unit, Scheduler
1908
1916
* Throttles by skipping value until `skipDuration` passes and then emits the next received value.
1909
1917
* <p>
1910
1918
* This differs from {@link #throttleLast} in that this only tracks passage of time whereas {@link #throttleLast} ticks at scheduled intervals.
1919
+ * <p>
1920
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleFirst.png">
1911
1921
*
1912
1922
* @param skipDuration
1913
1923
* Time to wait before sending another value after emitting last value.
@@ -1925,6 +1935,8 @@ public Observable<T> throttleFirst(long windowDuration, TimeUnit unit) {
1925
1935
* Throttles by skipping value until `skipDuration` passes and then emits the next received value.
1926
1936
* <p>
1927
1937
* This differs from {@link #throttleLast} in that this only tracks passage of time whereas {@link #throttleLast} ticks at scheduled intervals.
1938
+ * <p>
1939
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleFirst.png">
1928
1940
*
1929
1941
* @param skipDuration
1930
1942
* Time to wait before sending another value after emitting last value.
@@ -1942,6 +1954,8 @@ public Observable<T> throttleFirst(long skipDuration, TimeUnit unit, Scheduler s
1942
1954
* Throttles by returning the last value of each interval defined by 'intervalDuration'.
1943
1955
* <p>
1944
1956
* This differs from {@link #throttleFirst} in that this ticks along at a scheduled interval whereas {@link #throttleFirst} does not tick, it just tracks passage of time.
1957
+ * <p>
1958
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleLast.png">
1945
1959
*
1946
1960
* @param intervalDuration
1947
1961
* Duration of windows within with the last value will be chosen.
@@ -1958,6 +1972,8 @@ public Observable<T> throttleLast(long intervalDuration, TimeUnit unit) {
1958
1972
* Throttles by returning the last value of each interval defined by 'intervalDuration'.
1959
1973
* <p>
1960
1974
* This differs from {@link #throttleFirst} in that this ticks along at a scheduled interval whereas {@link #throttleFirst} does not tick, it just tracks passage of time.
1975
+ * <p>
1976
+ * <img width="640" src="https://github.com/Netflix/RxJava/wiki/images/rx-operators/throttleLast.png">
1961
1977
*
1962
1978
* @param intervalDuration
1963
1979
* Duration of windows within with the last value will be chosen.
0 commit comments