初始化后如何更改rxjava/rxscala运算符（.debounce）参数

Question

我在rxjava/rxscala中使用.防抖运算符来捕获一些发生在彼此给定时间段内的事件，但希望使给定时间段可控。时间段。防抖用途作为参数给出。

理想情况下，我希望能够通过考试。去抖动操作符使用的最新值确定去抖动使用的时间段的可观测值。差不多吧。去抖动（timePeriodController，TimeUnit.Seconds）。

我看到了。debounce可以选择DebounceSelector，并认为这可能是解决方案。

我也看到了。在这种情况下，flatMap可以以非常复杂的方式使用。

编辑：似乎在RxJS中。debounce可以使用durationSelector，但这在RxJava中目前是不可能的。我想知道是否有解决办法？

如果有任何帮助，我将不胜感激。干杯亚当

Answer 1

当需要更改计时器操作符的参数时，例如取消抖动时，我会使用switchMap（）操作符。

BehaviorSubject<Long> timer = BehaviorSubject.create(100);
...
timer
  .distinctUntilChanged()
  .switchMap( timerValue ->
    originalSource
      .debounce(timerValue))
  .subscribe(...);

每当计时器值改变时，防抖间隔就会改变。