Module: Concurrent::Throttle::PromisesIntegration

Included in:
Concurrent::Throttle
Defined in:
lib/concurrent/edge/throttle.rb

Instance Method Summary collapse

Instance Method Details

#throttled_future(*args, &task) ⇒ Promises::Future

Behaves as Promises::FactoryMethods#future but the future is throttled.

Returns:

See Also:



135
136
137
 
# File 'lib/concurrent/edge/throttle.rb', line 135

def throttled_future(*args, &task)
  trigger.chain(*args, &task).on_resolution! { release }
end

#throttled_future_chain {|trigger| ... } ⇒ Promises::Event, Promises::Future

Allows to throttle a chain of promises.

Examples:

throttle.throttled_future_chain do |trigger|
  trigger.
      # 2 throttled promises
      chain { 1 }.
      then(&:succ)
end

Yields:

  • (trigger) —

    a trigger which has to be used to build up a chain of promises, the last one is result of the block. When the last one resolves, Concurrent::Throttle#release is called on the throttle.

Yield Parameters:

Yield Returns:

Returns:



128
129
130
 
# File 'lib/concurrent/edge/throttle.rb', line 128

def throttled_future_chain(&throttled_futures)
  throttled_futures.call(trigger).on_resolution! { release }
end