Last active June 26, 2025 16:43
Save benjchristensen/e4524a308456f3c21c0b to your computer and use it in GitHub Desktop.
DebounceBuffer: Use publish(), debounce() and buffer() together to capture bursts of events.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.List; import java.util.concurrent.TimeUnit; import rx.Observable; import rx.Subscriber; import rx.schedulers.Schedulers; public class DebounceBuffer { public static void main(String args[]) { // debounce to the last value in each burst // intermittentBursts().debounce(10, TimeUnit.MILLISECONDS).toBlocking().forEach(System.out::println); /* The following will emit a buffered list as it is debounced */ // first we multicast the stream ... using refCount so it handles the subscribe/unsubscribe Observable<Integer> burstStream = intermittentBursts().take(20).publish().refCount(); // then we get the debounced version Observable<Integer> debounced = burstStream.debounce(10, TimeUnit.MILLISECONDS); // then the buffered one that uses the debounced stream to demark window start/stop Observable<List<Integer>> buffered = burstStream.buffer(debounced); // then we subscribe to the buffered stream so it does what we want buffered.toBlocking().forEach(System.out::println); } /** * This is an artificial source to demonstrate an infinite stream that bursts intermittently */ public static Observable<Integer> intermittentBursts() { return Observable.create((Subscriber<? super Integer> s) -> { while (!s.isUnsubscribed()) { // burst some number of items for (int i = 0; i < Math.random() * 20; i++) { s.onNext(i); } try { // sleep for a random amount of time // NOTE: Only using Thread.sleep here as an artificial demo. Thread.sleep((long) (Math.random() * 1000)); } catch (Exception e) { // do nothing } } }).subscribeOn(Schedulers.newThread()); // use newThread since we are using sleep to block } } This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters import java.util.List; import java.util.concurrent.TimeUnit; import rx.Observable; import rx.Subscriber; import rx.schedulers.Schedulers; /** * Variant of above that uses `publish(Func1<? super Observable<T>, ? extends Observable<R>> selector)` * which allows multicasting without the need to use `refcount()` which can result in race conditions. * */ public class DebounceBufferPublish { public static void main(String args[]) { /* The following will emit a buffered list as it is debounced */ Observable<List<Integer>> buffered = intermittentBursts().take(20).publish(stream -> { // inside the `publish` function we can access `stream` in a multicasted manner return stream.buffer(stream.debounce(10, TimeUnit.MILLISECONDS)); }); buffered.toBlocking().forEach(System.out::println); } /** * This is an artificial source to demonstrate an infinite stream that bursts intermittently */ public static Observable<Integer> intermittentBursts() { return Observable.create((Subscriber<? super Integer> s) -> { while (!s.isUnsubscribed()) { // burst some number of items for (int i = 0; i < Math.random() * 20; i++) { s.onNext(i); } try { // sleep for a random amount of time // NOTE: Only using Thread.sleep here as an artificial demo. Thread.sleep((long) (Math.random() * 1000)); } catch (Exception e) { // do nothing } } }).subscribeOn(Schedulers.newThread()); // use newThread since we are using sleep to block } } This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters [0] [0, 1, 2, 3, 4, 5, 6, 7] [0, 1, 2, 3, 4, 5, 6] [0, 1, 2, 3, 4, 5, 6] [0, 1, 2, 3, 4, 5] [0, 1, 2, 3] [0, 1, 2, 3] [0, 1, 2, 3, 4]You can’t perform that action at this time.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4