class Concurrent::Promises::RunFuturePromise

def process_on_blocker_resolution(future, index)
  internal_state = future.internal_state
  unless internal_state.fulfilled?
    resolve_with internal_state
    return 0
  end
  value               = internal_state.value
  continuation_future = @RunTest.call value
  if continuation_future
    add_delayed_of continuation_future
    continuation_future.add_callback_notify_blocked self, nil
  else
    resolve_with internal_state
  end
  1
end