class Concurrent::Promises::BlockedPromise
def on_blocker_resolution(future, index)
def on_blocker_resolution(future, index) countdown = process_on_blocker_resolution(future, index) resolvable = resolvable?(countdown, future, index) on_resolvable(future, index) if resolvable end