RxSmartThrottle

Observable.throttle with custom interval.

Example: Exponential Backoff

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

With the parameters above,

• throttle interval increases exponentially (1, 2, 4, 8...),
• until the resetWhen's next event.

After resetWhen, throttle interval is reset to 0 (meaning that next source's event will be forwarded immediately)

Install

Copy paste source file to your project for now. 👌

I'm just too lazy to support Carthage or CocoaPods. It's Saturday afternoon.

LICENSE

MIT