debounce, throttleFirst, and throttleLast are most conspicuously absent from Project Reactor's Flux. Do they have any counterparts?
The sample operators are the once relating to the behavior you're searching for.
sampleTimeout could be used as debounce.sampleFirst could be used as throttleFirst.sample could be used as throttleLast.
I've been struggling to understand how to use sampleTimeout to do a debounce so I though I would put it here in case someone else is looking for this:
The would be equivalent to a debounce of 200ms
myFlux.sampleTimeout(u -> Mono.empty().delaySubscription(Duration.ofMillis(200)))
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With