class Concurrent::Promises::AnyResolvedFuturePromise

def initialize(delayed, blockers_count, default_executor)
  super delayed, blockers_count, Future.new(self, default_executor)
end

def on_resolvable(resolved_future, index)
  resolve_with resolved_future.internal_state, false
end

def resolvable?(countdown, future, index)
  true
end