class RateThrottleClient::ExponentialIncreaseGradualDecrease

Attributes

decrease[RW]

Public Class Methods

new(*args, decrease: nil, **kargs) click to toggle source
Calls superclass method RateThrottleClient::Base::new
# File lib/rate_throttle_client/clients/exponential_increase_gradual_decrease.rb, line 5
def initialize(*args, decrease: nil, **kargs)
  super(*args, **kargs)
  @decrease = decrease || @min_sleep
end

Public Instance Methods

call(&block) click to toggle source
# File lib/rate_throttle_client/clients/exponential_increase_gradual_decrease.rb, line 10
def call(&block)
  sleep_for = @sleep_for
  sleep(sleep_for + jitter(sleep_for))

  while (req = yield) && req.status == 429
    sleep_for += @min_sleep

    @log.call(Info.new(sleep_for: sleep_for, request: req))
    sleep(sleep_for + jitter(sleep_for))

    sleep_for *= @multiplier
  end

  if sleep_for >= @decrease
    sleep_for -= @decrease
  else
    sleep_for = 0
  end

  @sleep_for = sleep_for

  req
end