RxSmartThrottle

使用自定义间隔的 Observable.throttle。

示例：指数退避

source
    .throttle(dueTime: { max($1 * 2, 1) }, // (E, RxTimeInterval) -> RxTimeInterval
              resetWhen: resetTrigger,     // Observable<U>
              latest: true,
              scheduler: scheduler)
    .disposed(by: disposeBag)

使用上述参数，

节流间隔以指数方式增长 (1, 2, 4, 8...)，
直到 resetWhen 的下一个事件。

在 resetWhen 之后，节流间隔被重置为 0 (这意味着，下一个 source 事件将立即转发)

安装

现在复制粘贴源文件到你的项目即可。👌

我就是懒得去支持 Carthage 或 CocoaPods。今天是星期六下午。

许可证

MIT