debounce、throttleFirst 和 throttleLast 的 Flux 等价物是什么

Question

debounce、throttleFirst 和 throttleLast 最明显地没有出现在 Project Reactor 的 Flux 中。他们有同行吗？

Answer 1

sample 运算符是与您正在搜索的行为相关的一次。

sampleTimeout 可以用作 debounce.
sampleFirst 可以用作 throttleFirst.
sample 可以用作 throttleLast。

Answer 2

我一直在努力理解如何使用 sampleTimeout 来做一个 debounce 所以我还是把它放在这里以防其他人正在寻找这个：

相当于 debounce 200 毫秒

myFlux.sampleTimeout(u -> Mono.empty().delaySubscription(Duration.ofMillis(200)))

What are the Flux equivalents of debounce, throttleFirst, and throttleLast