class ActiveStorage::Service::MirrorService
def perform_across_services(method, *args)
def perform_across_services(method, *args) tasks = each_service.collect do |service| Concurrent::Promise.execute(executor: @executor) do service.public_send method, *args end end tasks.each(&:value!) end