module Concurrent::Promises::Future::ThrottleIntegration

Public Instance Methods

rescue_throttled_by(throttle, *args, &block) click to toggle source

Behaves as {Future#rescue} but the it is throttled. @return [Future] @see Future#rescue

# File lib-edge/concurrent/edge/throttle.rb, line 191
def rescue_throttled_by(throttle, *args, &block)
  throttled_by(throttle) { |trigger| trigger.rescue(*args, &block) }
end
then_throttled_by(throttle, *args, &block) click to toggle source

Behaves as {Future#then} but the it is throttled. @return [Future] @see Future#then @!macro throttle.example.then_throttled_by

# File lib-edge/concurrent/edge/throttle.rb, line 184
def then_throttled_by(throttle, *args, &block)
  throttled_by(throttle) { |trigger| trigger.then(*args, &block) }
end